org.joda.time.Instant.now()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(8.6k)|赞(0)|评价(0)|浏览(182)

本文整理了Java中org.joda.time.Instant.now()方法的一些代码示例，展示了Instant.now()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Instant.now()方法的具体详情如下：
包路径：org.joda.time.Instant
类名称：Instant
方法名：now

Instant.now介绍

[英]Obtains an Instant set to the current system millisecond time.
[中]获取设置为当前系统毫秒时间的瞬间。

代码示例

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-kinesis

@Test
 public void encodingAndDecodingWorks() throws Exception {
  KinesisRecord record =
    new KinesisRecord(
      ByteBuffer.wrap("data".getBytes(StandardCharsets.UTF_8)),
      "sequence",
      128L,
      "partition",
      Instant.now(),
      Instant.now(),
      "stream",
      "shard");
  CoderProperties.coderDecodeEncodeEqual(new KinesisRecordCoder(), record);
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Test
public void testCoderEncodeDecodeEquals() throws Exception {
 CoderProperties.coderDecodeEncodeEqual(
   CODER, TimestampedValue.of(GlobalWindow.INSTANCE, Instant.now()));
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Test
public void testTerminationConditionsNever() {
 Watch.Growth.Never<Object> c = never();
 Integer state = c.forNewInput(Instant.now(), null);
 assertFalse(c.canStopPolling(Instant.now(), state));
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Test
public void testExplodeWindowsInNoWindowsCrash() {
 thrown.expect(IllegalArgumentException.class);
 WindowedValue.of("foo", Instant.now(), ImmutableList.of(), PaneInfo.NO_FIRING);
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
public void createKeyedBundleKeyed() {
 StructuralKey<String> key = StructuralKey.of("foo", StringUtf8Coder.of());
 CommittedBundle<KV<String, Integer>> keyedBundle =
   context.createKeyedBundle(key, downstream).commit(Instant.now());
 assertThat(keyedBundle.getKey(), equalTo(key));
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
public void createKeyedBundleKeyed() {
 StructuralKey<String> key = StructuralKey.of("foo", StringUtf8Coder.of());
 CommittedBundle<KV<String, Integer>> keyedBundle =
   context
     .<String, KV<String, Integer>>createKeyedBundle(key, downstream)
     .commit(Instant.now());
 assertThat(keyedBundle.getKey(), Matchers.equalTo(key));
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Test
public void testValues() {
 Instant now = Instant.now();
 TimestampedValue<String> tsv = TimestampedValue.of("foobar", now);
 assertEquals(now, tsv.getTimestamp());
 assertEquals("foobar", tsv.getValue());
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
public void commitAfterCommitShouldThrowException() {
 UncommittedBundle<Integer> bundle = bundleFactory.createRootBundle();
 bundle.add(WindowedValue.valueInGlobalWindow(1));
 CommittedBundle<Integer> firstCommit = bundle.commit(Instant.now());
 assertThat(firstCommit.getElements(), containsInAnyOrder(WindowedValue.valueInGlobalWindow(1)));
 thrown.expect(IllegalStateException.class);
 thrown.expectMessage("committed");
 bundle.commit(Instant.now());
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
public void commitAfterCommitShouldThrowException() {
 UncommittedBundle<Integer> bundle = bundleFactory.createRootBundle();
 bundle.add(WindowedValue.valueInGlobalWindow(1));
 CommittedBundle<Integer> firstCommit = bundle.commit(Instant.now());
 assertThat(firstCommit.getElements(), containsInAnyOrder(WindowedValue.valueInGlobalWindow(1)));
 thrown.expect(IllegalStateException.class);
 thrown.expectMessage("committed");
 bundle.commit(Instant.now());
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Test
public void testExplodeWindowsInOneWindowEquals() {
 Instant now = Instant.now();
 BoundedWindow window = new IntervalWindow(now.minus(1000L), now.plus(1000L));
 WindowedValue<String> value =
   WindowedValue.of("foo", now, window, PaneInfo.ON_TIME_AND_ONLY_FIRING);
 assertThat(Iterables.getOnlyElement(value.explodeWindows()), equalTo(value));
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
public void rootBundleSucceeds() {
 UncommittedBundle<byte[]> root = factory.createRootBundle();
 byte[] array = new byte[] {0, 1, 2};
 root.add(WindowedValue.valueInGlobalWindow(array));
 CommittedBundle<byte[]> committed = root.commit(Instant.now());
 assertThat(
   committed.getElements(), containsInAnyOrder(WindowedValue.valueInGlobalWindow(array)));
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
 public void createKeyedBundleKeyed() {
  CommittedBundle<KV<String, Integer>> keyedBundle =
    bundleFactory
      .<String, KV<String, Integer>>createKeyedBundle(
        StructuralKey.of("foo", StringUtf8Coder.of()), downstream)
      .commit(Instant.now());
  assertThat(keyedBundle.getKey().getKey(), Matchers.equalTo("foo"));
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Test
@Category(NeedsRunner.class)
public void testUnboundedInputRate() {
 long numElements = 5000;
 long elemsPerPeriod = 10L;
 Duration periodLength = Duration.millis(8);
 PCollection<Long> input =
   p.apply(GenerateSequence.from(0).to(numElements).withRate(elemsPerPeriod, periodLength));
 addCountingAsserts(input, 0, numElements);
 long expectedRuntimeMillis = (periodLength.getMillis() * numElements) / elemsPerPeriod;
 Instant startTime = Instant.now();
 p.run();
 Instant endTime = Instant.now();
 assertThat(endTime.isAfter(startTime.plus(expectedRuntimeMillis)), is(true));
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
 public void createKeyedBundleKeyed() {
  CommittedBundle<KV<String, Integer>> keyedBundle =
    bundleFactory
      .createKeyedBundle(StructuralKey.of("foo", StringUtf8Coder.of()), downstream)
      .commit(Instant.now());
  assertThat(keyedBundle.getKey().getKey(), equalTo("foo"));
 }
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
public void getUncommittedElementsEqualInput() {
 CommittedBundle<Integer> bundle =
   bundleFactory
     .<Integer>createBundle(created)
     .add(WindowedValue.valueInGlobalWindow(2))
     .commit(Instant.now());
 CommittedResult<PTransformNode> result =
   CommittedResult.create(
     StepTransformResult.withoutHold(transform).build(),
     Optional.of(bundle),
     Collections.emptyList(),
     EnumSet.noneOf(OutputType.class));
 assertThat(result.getUnprocessedInputs().get(), Matchers.equalTo(bundle));
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
public void unchangedSucceeds() {
 WindowedValue<byte[]> element = WindowedValue.valueInGlobalWindow("bar".getBytes(UTF_8));
 CommittedBundle<byte[]> elements =
   bundleFactory.createBundle(pcollection).add(element).commit(Instant.now());
 ModelEnforcement<byte[]> enforcement = factory.forBundle(elements, consumer);
 enforcement.beforeElement(element);
 enforcement.afterElement(element);
 enforcement.afterFinish(
   elements,
   StepTransformResult.<byte[]>withoutHold(consumer).build(),
   Collections.emptyList());
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
public void getUncommittedElementsEqualInput() {
 CommittedBundle<Integer> bundle =
   bundleFactory
     .createBundle(created)
     .add(WindowedValue.valueInGlobalWindow(2))
     .commit(Instant.now());
 CommittedResult<AppliedPTransform<?, ?, ?>> result =
   CommittedResult.create(
     StepTransformResult.withoutHold(transform).build(),
     Optional.of(bundle),
     Collections.emptyList(),
     EnumSet.noneOf(OutputType.class));
 assertThat(result.getUnprocessedInputs().get(), Matchers.equalTo(bundle));
}

代码示例来源：origin: org.apache.beam/beam-runners-core-java

@Test
 public void testInvokesLifecycleMethods() throws Exception {
  DoFn<Integer, String> fn = new LifecycleVerifyingFn();
  try (ProcessFnTester<Integer, String, SomeRestriction, Void> tester =
    new ProcessFnTester<>(
      Instant.now(),
      fn,
      BigEndianIntegerCoder.of(),
      SerializableCoder.of(SomeRestriction.class),
      MAX_OUTPUTS_PER_BUNDLE,
      MAX_BUNDLE_DURATION)) {
   tester.startElement(42, new SomeRestriction());
  }
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-core

@Test
public void testUnboundedDisplayData() {
 Duration maxReadTime = Duration.standardHours(5);
 SerializableFunction<Long, Instant> timestampFn = input -> Instant.now();
 PTransform<?, ?> input =
   GenerateSequence.from(0).to(1234).withMaxReadTime(maxReadTime).withTimestampFn(timestampFn);
 DisplayData displayData = DisplayData.from(input);
 assertThat(displayData, hasDisplayItem("maxReadTime", maxReadTime));
 assertThat(displayData, hasDisplayItem("timestampFn", timestampFn.getClass()));
}

代码示例来源：origin: org.apache.beam/beam-runners-direct-java

@Test
public void rootBundleSucceedsIgnoresCoder() {
 WindowedValue<Record> one = WindowedValue.valueInGlobalWindow(new Record());
 WindowedValue<Record> two = WindowedValue.valueInGlobalWindow(new Record());
 CommittedBundle<Record> root =
   factory.<Record>createRootBundle().add(one).add(two).commit(Instant.now());
 assertThat(root.getElements(), containsInAnyOrder(one, two));
}

内容来源于网络，如有侵权，请联系作者删除！

Instant

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com