com.microsoft.azure.kusto.ingest.source

Class BlobSourceInfo

java.lang.Object

com.microsoft.azure.kusto.ingest.source.BlobSourceInfo

All Implemented Interfaces:

TraceableAttributes, SourceInfo

public class BlobSourceInfo
extends Object

Constructor Summary

Constructors

Constructor and Description
BlobSourceInfo(String blobPath)
BlobSourceInfo(String blobPath, CompressionType compressionType)
BlobSourceInfo(String blobPath, CompressionType compressionType, UUID sourceId)

Method Summary

Modifier and Type	Method and Description
static BlobSourceInfo	fromFile(String blobPath, FileSourceInfo fileSourceInfo, CompressionType sourceCompressionType, boolean gotCompressed)
static BlobSourceInfo	fromStream(String blobPath, Integer size, StreamSourceInfo streamSourceInfo)
Long	getBlobExactSize()
String	getBlobPath()
CompressionType	getCompressionType()
UUID	getSourceId()
Map<String,String>	getTracingAttributes()
void	setBlobPath(String blobPath)
void	setCompressionType(CompressionType compressionType)
void	setSourceId(UUID sourceId)
void	validate() Checks that this SourceInfo is defined appropriately.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BlobSourceInfo

public BlobSourceInfo(String blobPath)

BlobSourceInfo

public BlobSourceInfo(String blobPath,
                      CompressionType compressionType)

BlobSourceInfo

public BlobSourceInfo(String blobPath,
                      CompressionType compressionType,
                      UUID sourceId)

Method Detail

getBlobPath

public String getBlobPath()

setBlobPath

public void setBlobPath(String blobPath)

getBlobExactSize

public Long getBlobExactSize()

getCompressionType

public CompressionType getCompressionType()

setCompressionType

public void setCompressionType(CompressionType compressionType)

validate

public void validate()

Description copied from interface: SourceInfo

Checks that this SourceInfo is defined appropriately.

getTracingAttributes

public Map<String,String> getTracingAttributes()

Specified by:

getTracingAttributes in interface TraceableAttributes

fromFile

public static BlobSourceInfo fromFile(String blobPath,
                                      FileSourceInfo fileSourceInfo,
                                      CompressionType sourceCompressionType,
                                      boolean gotCompressed)

fromStream

public static BlobSourceInfo fromStream(String blobPath,
                                        Integer size,
                                        StreamSourceInfo streamSourceInfo)

getSourceId

public UUID getSourceId()

Specified by:

getSourceId in interface SourceInfo

setSourceId

public void setSourceId(UUID sourceId)

Specified by:

setSourceId in interface SourceInfo