@Test public void testGetWorkingFileName() throws Exception { String workingFileName = underTest.getWorkingFileName(null, "tpc", "brk1", 1, "1388538000000"); assertEquals("data.tpc.brk1.1.1388538000000", workingFileName); }
@Override public String getWorkingFileName(JobContext context, String topic, String brokerId, int partitionId, String encodedPartition) { return "data." + topic.replace('.', '_') + "." + brokerId + "." + partitionId + "." + encodedPartition; }
BaseTimeBasedPartitioner extends Partitioner { @Override public String getWorkingFileName(JobContext context, String topic, String brokerId, int partitionId, String encodedPartition) { return "data." + topic.replace('.', '_') + "." + brokerId + "." + partitionId + "." + encodedPartition; } }
BaseTimeBasedPartitioner extends Partitioner { @Override public String getWorkingFileName(JobContext context, String topic, String brokerId, int partitionId, String encodedPartition) { return "data." + topic.replace('.', '_') + "." + brokerId + "." + partitionId + "." + encodedPartition; }  }
BaseTimeBasedPartitioner extends Partitioner { @Override public String getWorkingFileName(JobContext context, String topic, String brokerId, int partitionId, String encodedPartition) { return "data." + topic.replace('.', '_') + "." + brokerId + "." + partitionId + "." + encodedPartition; }  @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 getWorkingFileName(JobContext context, String topic, String brokerId, int partitionId, String encodedPartition) { return "data." + topic.replace('.', '_') + "." + brokerId + "." + partitionId + "." + encodedPartition; }  @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; }