本文整理了Java中org.apache.hadoop.hive.ql.plan.api.QueryPlan.setStartedIsSet方法的一些代码示例,展示了
本文整理了Java中org.apache.hadoop.hive.ql.plan.api.QueryPlan.setStartedIsSet
方法的一些代码示例,展示了QueryPlan.setStartedIsSet
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryPlan.setStartedIsSet
方法的具体详情如下:
包路径:org.apache.hadoop.hive.ql.plan.api.QueryPlan
类名称:QueryPlan
方法名:setStartedIsSet
QueryPlan.setStartedIsSet介绍
暂无
代码示例
代码示例来源:origin: apache/hive
public void setStarted(boolean started) {
this.started = started;
setStartedIsSet(true);
}
代码示例来源:origin: apache/drill
public void setStarted(boolean started) {
this.started = started;
setStartedIsSet(true);
}
代码示例来源:origin: apache/hive
@Override
public void clear() {
this.queries = null;
setDoneIsSet(false);
this.dOne= false;
setStartedIsSet(false);
this.started = false;
}
代码示例来源:origin: apache/hive
public QueryPlan(
List queries,
boolean done,
boolean started)
{
this();
this.queries = queries;
this.dOne= done;
setDoneIsSet(true);
this.started = started;
setStartedIsSet(true);
}
代码示例来源:origin: apache/drill
public QueryPlan(
List queries,
boolean done,
boolean started)
{
this();
this.queries = queries;
this.dOne= done;
setDoneIsSet(true);
this.started = started;
setStartedIsSet(true);
}
代码示例来源:origin: apache/drill
@Override
public void clear() {
this.queries = null;
setDoneIsSet(false);
this.dOne= false;
setStartedIsSet(false);
this.started = false;
}
代码示例来源:origin: apache/hive
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.started = iprot.readBool();
struct.setStartedIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
代码示例来源:origin: apache/hive
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, QueryPlan struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
org.apache.thrift.protocol.TList _list133 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
struct.queries = new ArrayList(_list133.size);
Query _elem134;
for (int _i135 = 0; _i135 <_list133.size; ++_i135)
{
_elem134 = new Query();
_elem134.read(iprot);
struct.queries.add(_elem134);
}
}
struct.setQueriesIsSet(true);
}
if (incoming.get(1)) {
struct.dOne= iprot.readBool();
struct.setDoneIsSet(true);
}
if (incoming.get(2)) {
struct.started = iprot.readBool();
struct.setStartedIsSet(true);
}
}
}
代码示例来源:origin: apache/drill
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.started = iprot.readBool();
struct.setStartedIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
代码示例来源:origin: apache/drill
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, QueryPlan struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
org.apache.thrift.protocol.TList _list133 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
struct.queries = new ArrayList(_list133.size);
Query _elem134;
for (int _i135 = 0; _i135 <_list133.size; ++_i135)
{
_elem134 = new Query();
_elem134.read(iprot);
struct.queries.add(_elem134);
}
}
struct.setQueriesIsSet(true);
}
if (incoming.get(1)) {
struct.dOne= iprot.readBool();
struct.setDoneIsSet(true);
}
if (incoming.get(2)) {
struct.started = iprot.readBool();
struct.setStartedIsSet(true);
}
}
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
public void setStarted(boolean started) {
this.started = started;
setStartedIsSet(true);
}
代码示例来源:origin: org.apache.hadoop.hive/hive-exec
public void setStarted(boolean started) {
this.started = started;
setStartedIsSet(true);
}
代码示例来源:origin: org.apache.hadoop.hive/hive-exec
public QueryPlan(
List queries,
boolean done,
boolean started)
{
this();
this.queries = queries;
this.dOne= done;
setDoneIsSet(true);
this.started = started;
setStartedIsSet(true);
}
代码示例来源:origin: org.apache.hadoop.hive/hive-exec
@Override
public void clear() {
this.queries = null;
setDoneIsSet(false);
this.dOne= false;
setStartedIsSet(false);
this.started = false;
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
public QueryPlan(
List queries,
boolean done,
boolean started)
{
this();
this.queries = queries;
this.dOne= done;
setDoneIsSet(true);
this.started = started;
setStartedIsSet(true);
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
@Override
public void clear() {
this.queries = null;
setDoneIsSet(false);
this.dOne= false;
setStartedIsSet(false);
this.started = false;
}
代码示例来源:origin: org.apache.hadoop.hive/hive-exec
if (field.type == TType.BOOL) {
this.started = iprot.readBool();
setStartedIsSet(true);
} else {
TProtocolUtil.skip(iprot, field.type);
代码示例来源:origin: com.facebook.presto.hive/hive-apache
if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
struct.started = iprot.readBool();
struct.setStartedIsSet(true);
} else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
代码示例来源:origin: com.facebook.presto.hive/hive-apache
@Override
public void read(org.apache.thrift.protocol.TProtocol prot, QueryPlan struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
{
org.apache.thrift.protocol.TList _list133 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
struct.queries = new ArrayList(_list133.size);
for (int _i134 = 0; _i134 <_list133.size; ++_i134)
{
Query _elem135; // required
_elem135 = new Query();
_elem135.read(iprot);
struct.queries.add(_elem135);
}
}
struct.setQueriesIsSet(true);
}
if (incoming.get(1)) {
struct.dOne= iprot.readBool();
struct.setDoneIsSet(true);
}
if (incoming.get(2)) {
struct.started = iprot.readBool();
struct.setStartedIsSet(true);
}
}
}