Skip to content

Commit df976b3

Browse files
committed
Use GMT timezone for Turtle serializers
1 parent ca2ba63 commit df976b3

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

src/main/java/ldbc/snb/datagen/serializer/snb/interactive/TurtlePersonActivitySerializer.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@ Linked Data Benchmark Council (http://www.ldbcouncil.org)
4545

4646
import java.io.IOException;
4747
import java.text.SimpleDateFormat;
48+
import java.util.TimeZone;
4849

4950

5051
/**
@@ -72,8 +73,8 @@ public String toString() {
7273

7374
@Override
7475
public void initialize(Configuration conf, int reducerId) throws IOException {
75-
7676
dateTimeFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSXXX");
77+
dateTimeFormat .setTimeZone(TimeZone.getTimeZone("GMT"));
7778
int numFiles = FileNames.values().length;
7879
writers = new HDFSWriter[numFiles];
7980
for (int i = 0; i < numFiles; ++i) {

src/main/java/ldbc/snb/datagen/serializer/snb/interactive/TurtlePersonSerializer.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ Linked Data Benchmark Council (http://www.ldbcouncil.org)
5050

5151
import java.io.IOException;
5252
import java.text.SimpleDateFormat;
53+
import java.util.TimeZone;
5354

5455

5556
public class TurtlePersonSerializer extends PersonSerializer {
@@ -77,6 +78,7 @@ public String toString() {
7778

7879
public void initialize(Configuration conf, int reducerId) throws IOException {
7980
dateTimeFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSXXX");
81+
dateTimeFormat .setTimeZone(TimeZone.getTimeZone("GMT"));
8082
int numFiles = FileNames.values().length;
8183
writers = new HDFSWriter[numFiles];
8284
for (int i = 0; i < numFiles; ++i) {

0 commit comments

Comments
 (0)