public class BroadcastVars
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
BroadcastVars(org.apache.spark.api.java.JavaSparkContext sc) |
Modifier and Type | Method and Description |
---|---|
DataSchema |
getDataSchema() |
java.lang.String |
getExpDir() |
java.lang.Boolean |
getLimitHitsPerSelector() |
java.lang.Integer |
getMaxBatches() |
java.lang.Integer |
getMaxHitsPerSelector() |
java.lang.String |
getOutput() |
Query |
getQuery() |
QueryInfo |
getQueryInfo() |
QuerySchema |
getQuerySchema() |
java.lang.Boolean |
getUseLocalCache() |
void |
setDataSchema(DataSchema dSchemaIn) |
void |
setExpDir(java.lang.String expDirIn) |
void |
setLimitHitsPerSelector(java.lang.Boolean limitHitsPerSelectorIn) |
void |
setMaxBatches(java.lang.Integer maxBatchesIn) |
void |
setMaxHitsPerSelector(java.lang.Integer maxHitsPerSelectorIn) |
void |
setOutput(java.lang.String outputIn) |
void |
setQuery(Query queryIn) |
void |
setQueryInfo(QueryInfo queryInfoIn) |
void |
setQuerySchema(QuerySchema qSchemaIn) |
void |
setUseLocalCache(java.lang.Boolean useLocalCacheInput) |
public BroadcastVars(org.apache.spark.api.java.JavaSparkContext sc)
public Query getQuery()
public void setQuery(Query queryIn)
public QueryInfo getQueryInfo()
public void setOutput(java.lang.String outputIn)
public java.lang.String getOutput()
public void setQueryInfo(QueryInfo queryInfoIn)
public void setQuerySchema(QuerySchema qSchemaIn)
public QuerySchema getQuerySchema()
public void setDataSchema(DataSchema dSchemaIn)
public DataSchema getDataSchema()
public void setUseLocalCache(java.lang.Boolean useLocalCacheInput)
public java.lang.Boolean getUseLocalCache()
public java.lang.Boolean getLimitHitsPerSelector()
public void setLimitHitsPerSelector(java.lang.Boolean limitHitsPerSelectorIn)
public java.lang.Integer getMaxHitsPerSelector()
public void setMaxHitsPerSelector(java.lang.Integer maxHitsPerSelectorIn)
public void setExpDir(java.lang.String expDirIn)
public java.lang.String getExpDir()
public java.lang.Integer getMaxBatches()
public void setMaxBatches(java.lang.Integer maxBatchesIn)