@Test public void testEncodePartition() throws Exception { long time = new DateTime(2014, 1, 1, 3, 0, 0, 0, DATE_TIME_ZONE).getMillis(); String partition = underTest.encodePartition(null, etlKeyWithTime(time)); assertEquals("1388538000000", partition); }
@Override public String encodePartition(JobContext context, IEtlKey key) { return Long.toString(DateUtils.getPartition(outfilePartitionMillis, key.getTime(), outputDirFormatter.getZone())); }
BaseTimeBasedPartitioner extends Partitioner { @Override public String encodePartition(JobContext context, IEtlKey key) { return Long.toString(DateUtils.getPartition(outfilePartitionMillis, key.getTime(), outputDirFormatter.getZone())); } }
BaseTimeBasedPartitioner extends Partitioner { @Override public String encodePartition(JobContext context, IEtlKey key) { return Long.toString(DateUtils.getPartition(outfilePartitionMillis, key.getTime(), outputDirFormatter.getZone())); }  }
BaseTimeBasedPartitioner extends Partitioner { @Override public String encodePartition(JobContext context, IEtlKey key) { return Long.toString(DateUtils.getPartition(outfilePartitionMillis, key.getTime(), outputDirFormatter.getZone())); }  @Override String encodePartition(JobContext context, IEtlKey key); @Override String generatePartitionedPath(JobContext context, String topic, String encodedPartition); @Override String generateFileName(JobContext context, String topic, String brokerId, int partitionId, int count,
      long offset, String encodedPartition); @Override String getWorkingFileName(JobContext context, String topic, String brokerId, int partitionId,
      String encodedPartition); }
BaseTimeBasedPartitioner extends Partitioner { @Override public String encodePartition(JobContext context, IEtlKey key) { return Long.toString(DateUtils.getPartition(outfilePartitionMillis, key.getTime(), outputDirFormatter.getZone())); }  @Override String encodePartition(JobContext context, IEtlKey key); @Override String generatePartitionedPath(JobContext context, String topic, String encodedPartition); @Override String generateFileName(JobContext context, String topic, String brokerId, int partitionId, int count,
      long offset, String encodedPartition); @Override String getWorkingFileName(JobContext context, String topic, String brokerId, int partitionId,
      String encodedPartition); static final String DEFAULT_TIME_ZONE; }