Package org.apache.druid.sql.calcite.external

Class ExternalDataSource

java.lang.Object

org.apache.druid.query.LeafDataSource

org.apache.druid.sql.calcite.external.ExternalDataSource

All Implemented Interfaces:

Cacheable, DataSource

public class ExternalDataSource
extends LeafDataSource

Represents external data for INSERT queries. Only used by the SQL layer, not by the query stack. Includes an InputSource and InputFormat, plus a RowSignature so the SQL planner has the type information necessary to validate and plan the query. This class is exercised in CalciteInsertDmlTest but is not currently exposed to end users.

Field Summary

Fields inherited from interface org.apache.druid.query.DataSource

JOIN_OPERATION_CACHE_ID, NOOP_CACHE_ID, TABLE_DATA_SOURCE_CACHE_ID

Constructor Summary

Constructors

Constructor	Description
ExternalDataSource(InputSource inputSource, InputFormat inputFormat, RowSignature signature)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
byte[]	getCacheKey()
InputFormat	getInputFormat()
InputSource	getInputSource()
RowSignature	getSignature()
Set<String>	getTableNames()
int	hashCode()
boolean	isCacheable(boolean isBroker)
boolean	isGlobal()
boolean	isProcessable()
String	toString()

Methods inherited from class org.apache.druid.query.LeafDataSource

createSegmentMapFunction, getChildren, withChildren

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.druid.query.DataSource

createSegmentPruner, withPolicies

Constructor Details

ExternalDataSource

public ExternalDataSource(InputSource inputSource,
 InputFormat inputFormat,
 RowSignature signature)

Method Details

getInputSource

public InputSource getInputSource()

getInputFormat

public InputFormat getInputFormat()

getSignature

public RowSignature getSignature()

getTableNames

public Set<String> getTableNames()

isCacheable

public boolean isCacheable(boolean isBroker)

isGlobal

public boolean isGlobal()

isProcessable

public boolean isProcessable()

getCacheKey

public byte[] getCacheKey()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object