@Test public void testGeneratePartitionedPath() throws Exception { String path = underTest.generatePartitionedPath(null, "tpc", "1388538000000"); assertEquals("tpc/bi-hourly/year=2014/month=janvier/day=01/hour=2", path); }
@Override public String generatePartitionedPath(JobContext context, String topic, String encodedPartition) { DateTime bucket = new DateTime(Long.valueOf(encodedPartition)); return topic + "/" + bucket.toString(outputDirFormatter); }
BaseTimeBasedPartitioner extends Partitioner { @Override public String generatePartitionedPath(JobContext context, String topic, String encodedPartition) { DateTime bucket = new DateTime(Long.valueOf(encodedPartition)); return topic + "/" + bucket.toString(outputDirFormatter); } }
BaseTimeBasedPartitioner extends Partitioner { @Override public String generatePartitionedPath(JobContext context, String topic, String encodedPartition) { DateTime bucket = new DateTime(Long.valueOf(encodedPartition)); return topic + "/" + bucket.toString(outputDirFormatter); }  }
BaseTimeBasedPartitioner extends Partitioner { @Override public String generatePartitionedPath(JobContext context, String topic, String encodedPartition) { DateTime bucket = new DateTime(Long.valueOf(encodedPartition)); return topic + "/" + bucket.toString(outputDirFormatter); }  @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 generatePartitionedPath(JobContext context, String topic, String encodedPartition) { DateTime bucket = new DateTime(Long.valueOf(encodedPartition)); return topic + "/" + bucket.toString(outputDirFormatter); }  @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; }