diff --git a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy index 10aa127ed806..e0a6b13d7794 100644 --- a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy +++ b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy @@ -1542,7 +1542,6 @@ class BeamModulePlugin implements Plugin { "ExtendsAutoValue", "InlineMeSuggester", "InvalidBlockTag", - "JavaTimeDefaultTimeZone", "JodaConstructors", "MixedMutabilityReturnType", "PreferJavaTimeOverload", diff --git a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/ArtifactUtils.java b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/ArtifactUtils.java index b74ec23dd7ec..854651ae1f14 100644 --- a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/ArtifactUtils.java +++ b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/ArtifactUtils.java @@ -24,7 +24,7 @@ import com.google.cloud.storage.Storage; import com.google.cloud.storage.StorageOptions; import java.time.Instant; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.UUID; import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Strings; @@ -37,7 +37,7 @@ private ArtifactUtils() {} public static String createRunId() { return String.format( "%s-%s", - DateTimeFormatter.ofPattern("yyyyMMdd").withZone(ZoneId.of("UTC")).format(Instant.now()), + DateTimeFormatter.ofPattern("yyyyMMdd").withZone(ZoneOffset.UTC).format(Instant.now()), // by default some templates replace "dd" in the output paths with a day of the month, since // this id is used as a part of output paths replace "dd" with an arbitrary number to avoid // confusion and potential flaky tests diff --git a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/DatastoreUtils.java b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/DatastoreUtils.java index ebefa8d28272..ded0dc66de0f 100644 --- a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/DatastoreUtils.java +++ b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/DatastoreUtils.java @@ -18,7 +18,7 @@ package org.apache.beam.it.gcp.datastore; import java.time.Instant; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.CaseFormat; @@ -44,7 +44,7 @@ static String createTestId(String prefix) { CaseFormat.UPPER_CAMEL.converterTo(CaseFormat.LOWER_HYPHEN).convert(prefix); String formattedTimestamp = DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS") - .withZone(ZoneId.of("UTC")) + .withZone(ZoneOffset.UTC) .format(Instant.now()); return String.format("%s-%s", convertedPrefix, formattedTimestamp); } diff --git a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubUtils.java b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubUtils.java index f195232b2350..916a299a7c18 100644 --- a/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubUtils.java +++ b/it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubUtils.java @@ -24,7 +24,7 @@ import com.google.pubsub.v1.Topic; import com.google.pubsub.v1.TopicName; import java.time.Instant; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.regex.Matcher; import java.util.regex.Pattern; @@ -108,7 +108,7 @@ static String createTestId(String prefix) { CaseFormat.UPPER_CAMEL.converterTo(CaseFormat.LOWER_HYPHEN).convert(prefix); String formattedTimestamp = DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS") - .withZone(ZoneId.of("UTC")) + .withZone(ZoneOffset.UTC) .format(Instant.now()); return String.format("%s-%s", convertedPrefix, formattedTimestamp); } diff --git a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOLT.java b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOLT.java index 17ae820f1c13..1c28b9078530 100644 --- a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOLT.java +++ b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOLT.java @@ -29,7 +29,7 @@ import java.nio.ByteBuffer; import java.text.ParseException; import java.time.Duration; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.Arrays; @@ -126,7 +126,7 @@ public void setup() { String tableName = "io-bq-table-" + DateTimeFormatter.ofPattern("MMddHHmmssSSS") - .withZone(ZoneId.of("UTC")) + .withZone(ZoneOffset.UTC) .format(java.time.Instant.now()) + UUID.randomUUID().toString().substring(0, 10); tableQualifier = String.format("%s:%s.%s", project, resourceManager.getDatasetId(), tableName); diff --git a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOST.java b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOST.java index 6ccb52bdc0b8..14c83e48308a 100644 --- a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOST.java +++ b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOST.java @@ -27,7 +27,7 @@ import java.io.IOException; import java.nio.ByteBuffer; import java.time.Duration; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.Arrays; @@ -112,7 +112,7 @@ public void setup() { tableName = "io-bq-source-table-" + DateTimeFormatter.ofPattern("MMddHHmmssSSS") - .withZone(ZoneId.of("UTC")) + .withZone(ZoneOffset.UTC) .format(java.time.Instant.now()) + UUID.randomUUID().toString().substring(0, 10); tableQualifier = String.format("%s:%s.%s", project, resourceManager.getDatasetId(), tableName); diff --git a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOLT.java b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOLT.java index e2ef7ba33bdf..8f3de1b58f40 100644 --- a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOLT.java +++ b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOLT.java @@ -28,7 +28,7 @@ import java.io.Serializable; import java.text.ParseException; import java.time.Duration; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.Map; import java.util.Objects; @@ -76,7 +76,7 @@ public void setup() throws IOException { tableName = "io_spanner_" + DateTimeFormatter.ofPattern("MMddHHmmssSSS") - .withZone(ZoneId.of("UTC")) + .withZone(ZoneOffset.UTC) .format(java.time.Instant.now()) + UUID.randomUUID().toString().replace("-", "").substring(0, 10); diff --git a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOST.java b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOST.java index 22841859ddab..76312b3e10fb 100644 --- a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOST.java +++ b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOST.java @@ -28,7 +28,7 @@ import java.io.Serializable; import java.text.ParseException; import java.time.Duration; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.List; import java.util.Map; @@ -89,7 +89,7 @@ public void setup() throws IOException { tableName = "io_spanner_" + DateTimeFormatter.ofPattern("MMddHHmmssSSS") - .withZone(ZoneId.of("UTC")) + .withZone(ZoneOffset.UTC) .format(java.time.Instant.now()) + UUID.randomUUID().toString().replace("-", "").substring(0, 10); diff --git a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/FileBasedIOLT.java b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/FileBasedIOLT.java index 6a4b7848d508..58ba88d900e8 100644 --- a/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/FileBasedIOLT.java +++ b/it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/FileBasedIOLT.java @@ -24,7 +24,7 @@ import java.io.IOException; import java.text.ParseException; import java.time.Duration; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.Base64; import java.util.Map; @@ -151,7 +151,7 @@ public void setup() { String tempDirName = "textiolt-" + DateTimeFormatter.ofPattern("MMddHHmmssSSS") - .withZone(ZoneId.of("UTC")) + .withZone(ZoneOffset.UTC) .format(java.time.Instant.now()) + UUID.randomUUID().toString().substring(0, 10); resourceManager.registerTempDir(tempDirName); diff --git a/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOLT.java b/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOLT.java index f2a2c73ee879..c20699d61a55 100644 --- a/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOLT.java +++ b/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOLT.java @@ -23,7 +23,7 @@ import com.google.auto.value.AutoValue; import java.io.IOException; import java.time.Duration; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.Map; import java.util.UUID; @@ -78,7 +78,7 @@ public void setup() throws IOException { kafkaTopic = "io-kafka-" + DateTimeFormatter.ofPattern("MMddHHmmssSSS") - .withZone(ZoneId.of("UTC")) + .withZone(ZoneOffset.UTC) .format(java.time.Instant.now()) + UUID.randomUUID().toString().substring(0, 10); diff --git a/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOST.java b/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOST.java index 9303baf8495f..bb1cb37a11b6 100644 --- a/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOST.java +++ b/it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOST.java @@ -24,7 +24,7 @@ import java.io.IOException; import java.text.ParseException; import java.time.Duration; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.format.DateTimeFormatter; import java.util.Collections; import java.util.List; @@ -116,7 +116,7 @@ public void setup() { kafkaTopic = "io-kafka-" + DateTimeFormatter.ofPattern("MMddHHmmssSSS") - .withZone(ZoneId.of("UTC")) + .withZone(ZoneOffset.UTC) .format(java.time.Instant.now()) + UUID.randomUUID().toString().substring(0, 10); adminClient.createTopics(Collections.singletonList(new NewTopic(kafkaTopic, 1, (short) 3))); diff --git a/sdks/java/extensions/sbe/src/test/java/org/apache/beam/sdk/extensions/sbe/SbeLogicalTypesTest.java b/sdks/java/extensions/sbe/src/test/java/org/apache/beam/sdk/extensions/sbe/SbeLogicalTypesTest.java index 8d0f4b11f5cf..b46703ec70c2 100644 --- a/sdks/java/extensions/sbe/src/test/java/org/apache/beam/sdk/extensions/sbe/SbeLogicalTypesTest.java +++ b/sdks/java/extensions/sbe/src/test/java/org/apache/beam/sdk/extensions/sbe/SbeLogicalTypesTest.java @@ -25,6 +25,7 @@ import java.time.OffsetDateTime; import java.time.OffsetTime; import java.time.ZoneId; +import java.time.ZoneOffset; import org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.LocalMktDate; import org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.TZTimeOnly; import org.apache.beam.sdk.extensions.sbe.SbeLogicalTypes.TZTimestamp; @@ -59,7 +60,7 @@ public void testTzTimestamp() { @Test public void testUtcTimeOnly() { - LocalTime time = LocalTime.now(); + LocalTime time = LocalTime.now(ZoneOffset.UTC); UTCTimeOnly timeOnly = new UTCTimeOnly(); LocalTime afterConversions = timeOnly.toInputType(timeOnly.toBaseType(time)); @@ -79,7 +80,7 @@ public void testTzTimeOnly() { @Test public void testUtcDateOnly() { - LocalDate date = LocalDate.now(); + LocalDate date = LocalDate.now(ZoneOffset.UTC); UTCDateOnly dateOnly = new UTCDateOnly(); LocalDate afterConversions = dateOnly.toInputType(dateOnly.toBaseType(date)); @@ -89,7 +90,7 @@ public void testUtcDateOnly() { @Test public void testLocalMktDate() { - LocalDate date = LocalDate.now(); + LocalDate date = LocalDate.now(ZoneOffset.UTC); LocalMktDate localMktDate = new LocalMktDate(); LocalDate afterConversions = localMktDate.toInputType(localMktDate.toBaseType(date)); diff --git a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamSqlRowCoderTest.java b/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamSqlRowCoderTest.java index 41cd9ed2d7ef..e2ed6d473abf 100644 --- a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamSqlRowCoderTest.java +++ b/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamSqlRowCoderTest.java @@ -21,6 +21,7 @@ import java.time.LocalDate; import java.time.LocalDateTime; import java.time.LocalTime; +import java.time.ZoneOffset; import org.apache.beam.sdk.coders.Coder; import org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils; import org.apache.beam.sdk.schemas.Schema; @@ -70,9 +71,9 @@ public void encodeAndDecode() throws Exception { 1.1, BigDecimal.ZERO, "hello", - LocalTime.now(), - LocalDate.now(), - LocalDateTime.now(), + LocalTime.now(ZoneOffset.UTC), + LocalDate.now(ZoneOffset.UTC), + LocalDateTime.now(ZoneOffset.UTC), DateTime.now().toInstant(), true) .build(); diff --git a/sdks/java/io/azure/src/test/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystemTest.java b/sdks/java/io/azure/src/test/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystemTest.java index 83ffcd066f58..76edb90f4b87 100644 --- a/sdks/java/io/azure/src/test/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystemTest.java +++ b/sdks/java/io/azure/src/test/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystemTest.java @@ -46,6 +46,7 @@ import java.nio.channels.WritableByteChannel; import java.time.Duration; import java.time.OffsetDateTime; +import java.time.ZoneOffset; import java.util.ArrayList; import java.util.Arrays; import java.util.List; @@ -111,7 +112,7 @@ public void beforeClass() { when(mockedBlobClient.getBlockBlobClient()).thenReturn(mockedBlockBlob); when(mockedBlobClient.getProperties()).thenReturn(mockedProperties); when(mockedProperties.getBlobSize()).thenReturn(Long.valueOf(1)); - when(mockedProperties.getLastModified()).thenReturn(OffsetDateTime.now()); + when(mockedProperties.getLastModified()).thenReturn(OffsetDateTime.now(ZoneOffset.UTC)); when(mockedContainerClient.listBlobs(any(ListBlobsOptions.class), any(Duration.class))) .thenReturn(mockedPagedIterable); when(mockedContainerClient.listBlobsByHierarchy(any(String.class))) diff --git a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-common/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTestUtils.java b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-common/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTestUtils.java index 102dfffdb0f5..41c8082989b7 100644 --- a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-common/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTestUtils.java +++ b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-common/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTestUtils.java @@ -35,6 +35,7 @@ import java.nio.charset.StandardCharsets; import java.time.Duration; import java.time.LocalDateTime; +import java.time.ZoneOffset; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; @@ -343,7 +344,7 @@ static long refreshIndexAndGetCurrentNumDocs( static List createDocuments(long numDocs, InjectionMode injectionMode) { ArrayList data = new ArrayList<>(); - LocalDateTime baseDateTime = LocalDateTime.now(); + LocalDateTime baseDateTime = LocalDateTime.now(ZoneOffset.UTC); for (int i = 0; i < numDocs; i++) { int index = i % FAMOUS_SCIENTISTS.length; // insert 2 malformed documents diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java index 74032c36438e..d9805a6f4e06 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java @@ -290,7 +290,7 @@ public abstract static class Builder { .appendFraction(java.time.temporal.ChronoField.NANO_OF_SECOND, 0, 9, true) .appendLiteral(" UTC") .toFormatter() - .withZone(java.time.ZoneId.of("UTC")); + .withZone(ZoneOffset.UTC); } private static final Map BEAM_TO_BIGQUERY_TYPE_MAPPING = diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProtoTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProtoTest.java index b4f2fa6aa241..4232011e5628 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProtoTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProtoTest.java @@ -35,6 +35,7 @@ import java.time.LocalDate; import java.time.LocalDateTime; import java.time.LocalTime; +import java.time.ZoneOffset; import java.time.temporal.ChronoUnit; import java.util.HashMap; import java.util.List; @@ -252,9 +253,9 @@ public class BeamRowToStorageApiProtoTest { .withFieldValue("arrayValue", ImmutableList.of("one", "two", "red", "blue")) .withFieldValue("arrayNullValue", null) .withFieldValue("iterableValue", ImmutableList.of("blue", "red", "two", "one")) - .withFieldValue("sqlDateValue", LocalDate.now()) - .withFieldValue("sqlTimeValue", LocalTime.now()) - .withFieldValue("sqlDatetimeValue", LocalDateTime.now()) + .withFieldValue("sqlDateValue", LocalDate.now(ZoneOffset.UTC)) + .withFieldValue("sqlTimeValue", LocalTime.now(ZoneOffset.UTC)) + .withFieldValue("sqlDatetimeValue", LocalDateTime.now(ZoneOffset.UTC)) .withFieldValue("sqlTimestampValue", java.time.Instant.now().plus(123, ChronoUnit.MICROS)) .withFieldValue("enumValue", TEST_ENUM.valueOf("RED")) .build(); diff --git a/sdks/java/io/influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/GenerateData.java b/sdks/java/io/influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/GenerateData.java index a323265e3dd7..27e6fa3b4660 100644 --- a/sdks/java/io/influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/GenerateData.java +++ b/sdks/java/io/influxdb/src/test/java/org/apache/beam/sdk/io/influxdb/GenerateData.java @@ -20,7 +20,7 @@ import java.time.LocalDate; import java.time.LocalDateTime; import java.time.LocalTime; -import java.time.ZoneId; +import java.time.ZoneOffset; import java.time.ZonedDateTime; import java.util.ArrayList; import java.util.List; @@ -40,13 +40,13 @@ static List getMetric(String metric, int number) { m.addField("field2", random.nextInt(100)); LocalDateTime time = LocalDateTime.of( - LocalDate.now(), + LocalDate.now(ZoneOffset.UTC), LocalTime.of( random.nextInt(24), random.nextInt(60), random.nextInt(60), random.nextInt(999999999 + 1))); - ZonedDateTime zdt = time.atZone(ZoneId.of("America/Los_Angeles")); + ZonedDateTime zdt = time.atZone(ZoneOffset.UTC); m.setTime(zdt.toInstant().toEpochMilli()); m.setTimeUnit(TimeUnit.MILLISECONDS); element.add(m.getLineProtocol()); @@ -64,13 +64,13 @@ static List getMultipleMetric(List metrics, int number) { m.addField("field2", random.nextInt(100)); LocalDateTime time = LocalDateTime.of( - LocalDate.now(), + LocalDate.now(ZoneOffset.UTC), LocalTime.of( random.nextInt(24), random.nextInt(60), random.nextInt(60), random.nextInt(999999999 + 1))); - ZonedDateTime zdt = time.atZone(ZoneId.of("America/Los_Angeles")); + ZonedDateTime zdt = time.atZone(ZoneOffset.UTC); m.setTime(zdt.toInstant().toEpochMilli()); m.setTimeUnit(TimeUnit.MILLISECONDS); element.add(m.getLineProtocol());