public class CloudFilesDataSegmentPusher extends Object implements io.druid.segment.loading.DataSegmentPusher
Constructor and Description |
---|
CloudFilesDataSegmentPusher(org.jclouds.rackspace.cloudfiles.v1.CloudFilesApi cloudFilesApi,
CloudFilesDataSegmentPusherConfig config,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and Description |
---|---|
String |
getPathForHadoop(String dataSource) |
io.druid.timeline.DataSegment |
push(File indexFilesDir,
io.druid.timeline.DataSegment inSegment) |
@Inject public CloudFilesDataSegmentPusher(org.jclouds.rackspace.cloudfiles.v1.CloudFilesApi cloudFilesApi, CloudFilesDataSegmentPusherConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
public String getPathForHadoop(String dataSource)
getPathForHadoop
in interface io.druid.segment.loading.DataSegmentPusher
public io.druid.timeline.DataSegment push(File indexFilesDir, io.druid.timeline.DataSegment inSegment) throws IOException
push
in interface io.druid.segment.loading.DataSegmentPusher
IOException
Copyright © 2011–2016. All rights reserved.