Java Meta类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.calcite.avatica.Meta类的典型用法代码示例。如果您正苦于以下问题：Java Meta类的具体用法？Java Meta怎么用？Java Meta使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Meta类属于org.apache.calcite.avatica包，在下文中一共展示了Meta类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: create

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
public static JdbcResultSet create(String connectionId, int statementId,
    ResultSet resultSet, int maxRowCount, Meta.Signature signature) {
  try {
    final Calendar calendar = DateTimeUtils.calendar();
    final int fetchRowCount;
    if (maxRowCount == JdbcMeta.UNLIMITED_COUNT) {
      fetchRowCount = -1;
    } else if (maxRowCount < 0L) {
      fetchRowCount = AvaticaStatement.DEFAULT_FETCH_SIZE;
    } else if (maxRowCount > AvaticaStatement.DEFAULT_FETCH_SIZE) {
      fetchRowCount = AvaticaStatement.DEFAULT_FETCH_SIZE;
    } else {
      fetchRowCount = maxRowCount;
    }
    final Meta.Frame firstFrame = frame(null, resultSet, 0, fetchRowCount, calendar,
        Optional.of(signature));
    if (firstFrame.done) {
      resultSet.close();
    }
    return new JdbcResultSet(connectionId, statementId, true, signature,
        firstFrame);
  } catch (SQLException e) {
    throw new RuntimeException(e);
  }
}

开发者ID:apache，项目名称:calcite-avatica，代码行数:26，代码来源:JdbcResultSet.java

示例2: fetch

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
public Frame fetch(StatementHandle h, long offset, int fetchMaxRowCount) throws
    NoSuchStatementException, MissingResultsException {
  LOG.trace("fetching {} offset:{} fetchMaxRowCount:{}", h, offset, fetchMaxRowCount);
  try {
    final StatementInfo statementInfo = statementCache.getIfPresent(h.id);
    if (null == statementInfo) {
      // Statement might have expired, or never existed on this server.
      throw new NoSuchStatementException(h);
    }

    if (!statementInfo.isResultSetInitialized()) {
      // The Statement exists, but the results are missing. Need to call syncResults(...)
      throw new MissingResultsException(h);
    }
    if (statementInfo.getResultSet() == null) {
      return Frame.EMPTY;
    } else {
      return JdbcResultSet.frame(statementInfo, statementInfo.getResultSet(), offset,
          fetchMaxRowCount, calendar, Optional.<Meta.Signature>absent());
    }
  } catch (SQLException e) {
    throw propagate(e);
  }
}

开发者ID:apache，项目名称:calcite-avatica，代码行数:25，代码来源:JdbcMeta.java

示例3: create

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override public ResultSet create(AvaticaType elementType, Iterable<Object> elements) {
  // The ColumnMetaData for offset "1" in the ResultSet for an Array.
  ScalarType arrayOffsetType = ColumnMetaData.scalar(Types.INTEGER, "INTEGER", Rep.PRIMITIVE_INT);
  // Two columns (types) in the ResultSet we will create
  List<ColumnMetaData> types = Arrays.asList(ColumnMetaData.dummy(arrayOffsetType, false),
      ColumnMetaData.dummy(elementType, true));
  List<List<Object>> rows = createResultSetRowsForArrayData(elements);
  // `(List<Object>) rows` is a compile error.
  @SuppressWarnings({ "unchecked", "rawtypes" })
  List<Object> untypedRows = (List<Object>) ((List) rows);
  try (ListIteratorCursor cursor = new ListIteratorCursor(rows.iterator())) {
    final String sql = "MOCKED";
    QueryState state = new QueryState(sql);
    Meta.Signature signature = new Meta.Signature(types, sql,
        Collections.<AvaticaParameter>emptyList(), Collections.<String, Object>emptyMap(),
        Meta.CursorFactory.LIST, Meta.StatementType.SELECT);
    AvaticaResultSetMetaData resultSetMetaData = new AvaticaResultSetMetaData(null, sql,
        signature);
    Meta.Frame frame = new Meta.Frame(0, true, untypedRows);
    AvaticaResultSet resultSet = new AvaticaResultSet(null, state, signature, resultSetMetaData,
        timeZone, frame);
    resultSet.execute2(cursor, types);
    return resultSet;
  }
}

开发者ID:apache，项目名称:calcite-avatica，代码行数:26，代码来源:ArrayFactoryImpl.java

示例4: ResultSetResponse

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@JsonCreator
public ResultSetResponse(
    @JsonProperty("connectionId") String connectionId,
    @JsonProperty("statementId") int statementId,
    @JsonProperty("ownStatement") boolean ownStatement,
    @JsonProperty("signature") Meta.Signature signature,
    @JsonProperty("firstFrame") Meta.Frame firstFrame,
    @JsonProperty("updateCount") long updateCount,
    @JsonProperty("rpcMetadata") RpcMetadataResponse rpcMetadata) {
  this.connectionId = connectionId;
  this.statementId = statementId;
  this.ownStatement = ownStatement;
  this.signature = signature;
  this.firstFrame = firstFrame;
  this.updateCount = updateCount;
  this.rpcMetadata = rpcMetadata;
}

开发者ID:apache，项目名称:calcite-avatica，代码行数:18，代码来源:Service.java

示例5: fromProto

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
static ResultSetResponse fromProto(Responses.ResultSetResponse msg) {
  String connectionId = null;
  if (msg.hasField(CONNECTION_ID_DESCRIPTOR)) {
    connectionId = msg.getConnectionId();
  }

  Meta.Signature signature = null;
  if (msg.hasField(SIGNATURE_DESCRIPTOR)) {
    signature = Meta.Signature.fromProto(msg.getSignature());
  }

  Meta.Frame frame = null;
  if (msg.hasField(FIRST_FRAME_DESCRIPTOR)) {
    frame = Meta.Frame.fromProto(msg.getFirstFrame());
  }

  RpcMetadataResponse metadata = null;
  if (msg.hasField(METADATA_DESCRIPTOR)) {
    metadata = RpcMetadataResponse.fromProto(msg.getMetadata());
  }

  return new ResultSetResponse(connectionId, msg.getStatementId(), msg.getOwnStatement(),
      signature, frame, msg.getUpdateCount(), metadata);
}

开发者ID:apache，项目名称:calcite-avatica，代码行数:25，代码来源:Service.java

示例6: deserialize

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override ConnectionSyncRequest deserialize(Message genericMsg) {
  final Requests.ConnectionSyncRequest msg = ProtobufService.castProtobufMessage(genericMsg,
      Requests.ConnectionSyncRequest.class);

  String connectionId = null;
  if (msg.hasField(CONNECTION_ID_DESCRIPTOR)) {
    connectionId = msg.getConnectionId();
  }

  Meta.ConnectionProperties connProps = null;
  if (msg.hasField(CONN_PROPS_DESCRIPTOR)) {
    connProps = ConnectionPropertiesImpl.fromProto(msg.getConnProps());
  }

  return new ConnectionSyncRequest(connectionId, connProps);
}

开发者ID:apache，项目名称:calcite-avatica，代码行数:17，代码来源:Service.java

示例7: apply

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
public ExecuteResponse apply(ExecuteRequest request) {
  try (final Context ignore = executeTimer.start()) {
    try {
      final Meta.ExecuteResult executeResult = meta.execute(request.statementHandle,
          request.parameterValues, AvaticaUtils.toSaturatedInt(request.maxRowCount));

      final List<ResultSetResponse> results = new ArrayList<>(executeResult.resultSets.size());
      for (Meta.MetaResultSet metaResultSet : executeResult.resultSets) {
        results.add(toResponse(metaResultSet));
      }
      return new ExecuteResponse(results, false, serverLevelRpcMetadata);
    } catch (NoSuchStatementException e) {
      return new ExecuteResponse(null, true, serverLevelRpcMetadata);
    }
  }
}

开发者ID:apache，项目名称:calcite-avatica，代码行数:17，代码来源:LocalService.java

示例8: toResultSet

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
private MetaResultSet toResultSet(Class clazz,
    Service.ResultSetResponse response) {
  if (response.updateCount != -1) {
    return MetaResultSet.count(response.connectionId, response.statementId,
        response.updateCount);
  }
  Signature signature0 = response.signature;
  if (signature0 == null) {
    final List<ColumnMetaData> columns =
        clazz == null
            ? Collections.<ColumnMetaData>emptyList()
            : fieldMetaData(clazz).columns;
    signature0 = Signature.create(columns,
        "?", Collections.<AvaticaParameter>emptyList(), CursorFactory.ARRAY,
        Meta.StatementType.SELECT);
  }
  return MetaResultSet.create(response.connectionId, response.statementId,
      response.ownStatement, signature0, response.firstFrame);
}

开发者ID:apache，项目名称:calcite-avatica，代码行数:20，代码来源:RemoteMeta.java

示例9: apply

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override public ExecuteResponse apply(ExecuteRequest request) {
  expectedParameterValues.addAll(request.parameterValues);

  final Meta.Signature signature =
      new Meta.Signature(Collections.<ColumnMetaData>emptyList(),
          "SELECT 1 FROM VALUE()",
          Collections.<AvaticaParameter>emptyList(),
          Collections.<String, Object>emptyMap(),
          CursorFactory.LIST, Meta.StatementType.SELECT);

  final Service.ResultSetResponse resultSetResponse =
      new Service.ResultSetResponse(UUID.randomUUID().toString(),
          RANDOM.nextInt(), false, signature, Meta.Frame.EMPTY, -1L, null);

  return new Service.ExecuteResponse(
      Collections.singletonList(resultSetResponse), false, null);
}

开发者ID:apache，项目名称:calcite-avatica，代码行数:18，代码来源:JsonHandlerTest.java

示例10: newPreparedStatement

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override
public DremioJdbc41PreparedStatement newPreparedStatement(AvaticaConnection connection,
                                                     StatementHandle h,
                                                     Meta.Signature signature,
                                                     int resultSetType,
                                                     int resultSetConcurrency,
                                                     int resultSetHoldability)
    throws SQLException {
  DremioConnectionImpl dremioConnection = (DremioConnectionImpl) connection;
  DremioClient client = dremioConnection.getClient();
  if (dremioConnection.getConfig().isServerPreparedStatementDisabled() || !client.getSupportedMethods().contains(ServerMethod.PREPARED_STATEMENT)) {
    // fallback to client side prepared statement
    return new DremioJdbc41PreparedStatement(dremioConnection, h, signature, null, resultSetType, resultSetConcurrency, resultSetHoldability);
  }
  return newServerPreparedStatement(dremioConnection, h, signature, resultSetType,
      resultSetConcurrency, resultSetHoldability);
}

开发者ID:dremio，项目名称:dremio-oss，代码行数:18，代码来源:DremioJdbc41Factory.java

示例11: newPreparedStatement

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override
public DrillJdbc41PreparedStatement newPreparedStatement(AvaticaConnection connection,
                                                     StatementHandle h,
                                                     Meta.Signature signature,
                                                     int resultSetType,
                                                     int resultSetConcurrency,
                                                     int resultSetHoldability)
    throws SQLException {
  DrillConnectionImpl drillConnection = (DrillConnectionImpl) connection;
  DrillClient client = drillConnection.getClient();
  if (drillConnection.getConfig().isServerPreparedStatementDisabled() || !client.getSupportedMethods().contains(ServerMethod.PREPARED_STATEMENT)) {
    // fallback to client side prepared statement
    return new DrillJdbc41PreparedStatement(drillConnection, h, signature, null, resultSetType, resultSetConcurrency, resultSetHoldability);
  }
  return newServerPreparedStatement(drillConnection, h, signature, resultSetType,
      resultSetConcurrency, resultSetHoldability);
}

开发者ID:axbaretto，项目名称:drill，代码行数:18，代码来源:DrillJdbc41Factory.java

示例12: DataProvider

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
public DataProvider(AtsdConnectionInfo connectionInfo, String query, StatementContext context,
					Meta.StatementType statementType) {
	final String endpoint;
	switch (statementType) {
		case SELECT: {
			if (context.isEncodeTags()) {
				endpoint = Location.SQL_ENDPOINT.getUrl(connectionInfo) + "?encodeTags=true";
			} else {
				endpoint = Location.SQL_ENDPOINT.getUrl(connectionInfo);
			}
			break;
		}
		case INSERT:
		case UPDATE: {
               endpoint = Location.COMMAND_ENDPOINT.getUrl(connectionInfo);
			break;
		}
		default: throw new IllegalArgumentException("Unsupported statement type: " + statementType);
	}
	this.contentDescription = new ContentDescription(endpoint, connectionInfo, query, context);
	logger.trace("Endpoint: {}", contentDescription.getEndpoint());
	this.contentProtocol = ProtocolFactory.create(SdkProtocolImpl.class, contentDescription);
	this.context = context;
}

开发者ID:axibase，项目名称:atsd-jdbc，代码行数:25，代码来源:DataProvider.java

示例13: testConverUpdateToSeriesWithLikeComparison

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Test
public void testConverUpdateToSeriesWithLikeComparison() throws SQLException {
    AtsdSqlUpdateConverter converter = (AtsdSqlUpdateConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.UPDATE, false);
    String sql = "update atsd_series set time=123456789, value=24.5, tags.unit='celcius' where entity='sensor-1' and " +
            "metric like 'jvm_memory_free'";
    List<String> commands = converter.convertToCommands(sql);
    Assert.assertEquals(1, commands.size());
    String expected = "series e:sensor-1 ms:123456789 t:unit=celcius m:jvm_memory_free=24.5";
    Assert.assertEquals(expected, commands.get(0));

    sql = "update atsd_series set time=123456789, value=24.5, tags.unit='celcius' where entity='sensor-1' and " +
            "metric like 'jvm#_memory#_free' escape '#'";
    commands = converter.convertToCommands(sql);
    Assert.assertEquals(1, commands.size());
    Assert.assertEquals(expected, commands.get(0));

    sql = "update atsd_series set time=123456789, value=24.5, tags.unit='celcius' where entity='sensor-1' and " +
            "metric like ? escape '#'";
    commands = converter.convertToCommands(sql, Arrays.<Object>asList("jvm#_memory#_free"));
    Assert.assertEquals(1, commands.size());
    Assert.assertEquals(expected, commands.get(0));
}

开发者ID:axibase，项目名称:atsd-jdbc，代码行数:23，代码来源:AtsdSqlConverterTest.java

示例14: testConvertInsertToSeriesWithTimestamp

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Test
public void testConvertInsertToSeriesWithTimestamp() throws SQLException, ParseException {
    final String sql = "INSERT INTO 'test.temperature' (entity, datetime, value, text, tags.unit) VALUES ('sensor-01', '2017-07-12 04:05:00.34567', " +
            "24.5, null, 'Celcius')";

    AtsdSqlInsertConverter converter = (AtsdSqlInsertConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.INSERT, true);
    List<String> commands = converter.convertToCommands(sql);
    Assert.assertEquals(1, commands.size());
    String expected = "series e:sensor-01 d:2017-07-12T04:05:00.345Z t:unit=Celcius m:test.temperature=24.5";
    Assert.assertEquals(expected, commands.get(0));

    converter = (AtsdSqlInsertConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.INSERT, false);
    commands = converter.convertToCommands(sql);
    Assert.assertEquals(1, commands.size());
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
    Date date = sdf.parse("2017-07-12T04:05:00.345Z");
    sdf.setTimeZone(TimeZone.getTimeZone("UTC"));
    expected = "series e:sensor-01 d:" + sdf.format(date) + " t:unit=Celcius m:test.temperature=24.5";
    Assert.assertEquals(expected, commands.get(0));
}

开发者ID:axibase，项目名称:atsd-jdbc，代码行数:21，代码来源:AtsdSqlConverterTest.java

示例15: testConvertInsertToSeriesAndMetricCommands

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Test
public void testConvertInsertToSeriesAndMetricCommands() throws SQLException {
    String sql = "INSERT INTO 'm-local-1' (entity, value, datetime, tags.test1, metric.tags.test1, metric.label, metric.enabled, metric.interpolate" +
            ", metric.timeZone, metric.description, metric.filter, metric.versioning, metric.units, metric.invalidValueAction, metric.maxValue" +
            ", metric.minValue) VALUES ('e-local-1', 123.0, '2017-07-12T08:05:02Z', 'S1', 'M1', 'label1', true, 'linear', 'UTC', 'description 1'" +
            ", 'filter 1', false, 'unit1', 'none', 12345, 123)";

    AtsdSqlInsertConverter converter = (AtsdSqlInsertConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.INSERT, true);
    List<String> commands = converter.convertToCommands(sql);
    Assert.assertEquals(2, commands.size());
    String expectedSeries = "series e:e-local-1 d:2017-07-12T08:05:02Z t:test1=S1 m:m-local-1=123.0";
    Assert.assertEquals(expectedSeries, commands.get(0));
    String expectedMetric = "metric m:m-local-1 b:true l:label1 d:\"description 1\" i:linear u:unit1 f:\"filter 1\" z:UTC v:false a:none min:123.0 " +
            "max:12345.0 t:test1=M1";
    Assert.assertEquals(expectedMetric, commands.get(1));
}

开发者ID:axibase，项目名称:atsd-jdbc，代码行数:17，代码来源:AtsdSqlConverterTest.java

示例16: testConvertUpdateToSeriesAndMetricCommands

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Test
public void testConvertUpdateToSeriesAndMetricCommands() throws SQLException {
    String sql = "UPDATE 'm-local-1' SET value=123, datetime='2017-07-12T08:05:02Z', tags.test1='S1', metric.tags.test1='M1', metric.label='label1'" +
            ", metric.enabled=true, metric.interpolate='linear', metric.timeZone='UTC', metric.description='description 1', metric.filter='filter 1'" +
            ", metric.versioning=false, metric.units='unit1', metric.invalidValueAction='none', metric.maxValue=12345, metric.minValue=123" +
            " WHERE entity='e-local-1'";

    AtsdSqlUpdateConverter converter = (AtsdSqlUpdateConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.UPDATE, true);
    List<String> commands = converter.convertToCommands(sql);
    Assert.assertEquals(2, commands.size());
    String expectedSeries = "series e:e-local-1 d:2017-07-12T08:05:02Z t:test1=S1 m:m-local-1=123.0";
    Assert.assertEquals(expectedSeries, commands.get(0));
    String expectedMetric = "metric m:m-local-1 b:true l:label1 d:\"description 1\" i:linear u:unit1 f:\"filter 1\" z:UTC v:false a:none min:123.0 " +
            "max:12345.0 t:test1=M1";
    Assert.assertEquals(expectedMetric, commands.get(1));
}

开发者ID:axibase，项目名称:atsd-jdbc，代码行数:17，代码来源:AtsdSqlConverterTest.java

示例17: data

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Parameterized.Parameters
public static Collection<Object[]> data() {
	return Arrays.asList(new Object[][]{
			{"SELECT * FROM jvm_memory_used", Meta.StatementType.SELECT},
			{"SELECT\n *\n  FROM jvm_memory_used", Meta.StatementType.SELECT},
			{"SELECT\t*\tFROM\tjvm_memory_used", Meta.StatementType.SELECT},
			{"SELECT * FROM jvm_memory_used", Meta.StatementType.SELECT},
			{"INSERT INTO test_table (entity, datetime, value) VALUES ('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{"INSERT\nINTO\ntest_table\n(entity, datetime, value)\nVALUES\n('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{"INSERT\tINTO\ttest_table\t(entity, datetime, value)\nVALUES\n('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{" INSERT INTO test_table (entity, datetime, value) VALUES ('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{"INSERT INTO \"test_table\" (entity, datetime, value) VALUES ('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{"UPDATE test_table SET value = -1 WHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
			{"UPDATE\ntest_table\nSET value = -1\nWHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
			{"UPDATE\ttest_table\tSET value = -1\tWHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
			{" UPDATE test_table SET value = -1 WHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
			{"UPDATE \"test_table\" SET value = -1 WHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
	});
}

开发者ID:axibase，项目名称:atsd-jdbc，代码行数:20，代码来源:StatementTypeByQueryRecognizerTest.java

示例18: createResultSet

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
protected MetaResultSet createResultSet(
        Map<String, Object> internalParameters, List<ColumnMetaData> columns,
        CursorFactory cursorFactory, final Frame firstFrame) {
    try {
        final CalciteConnectionImpl connection = getConnection();
        final AvaticaStatement statement = connection.createStatement();
        final CalcitePrepare.CalciteSignature<Object> signature =
                new CalcitePrepare.CalciteSignature<Object>("",
                        ImmutableList.<AvaticaParameter>of(), internalParameters, null,
                        columns, cursorFactory, ImmutableList.<RelCollation>of(), -1,
                        null, Meta.StatementType.SELECT) {
                    @Override
                    public Enumerable<Object> enumerable(
                            DataContext dataContext) {
                        return Linq4j.asEnumerable(firstFrame.rows);
                    }
                };
        return MetaResultSet.create(connection.id, statement.getId(), true,
                signature, firstFrame);
    } catch (SQLException e) {
        throw new RuntimeException(e);
    }
}

开发者ID:bitnine-oss，项目名称:octopus，代码行数:24，代码来源:CalciteMetaImpl.java

示例19: fetch

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override
public Frame fetch(StatementHandle h, long offset, int fetchMaxRowCount) {
    final CalciteConnectionImpl calciteConnection = getConnection();
    CalciteServerStatement stmt = calciteConnection.getServer().getStatement(h);
    final Signature signature = stmt.getSignature();
    final Iterator<Object> iterator;
    if (stmt.getResultSet() == null) {
        final Iterable<Object> iterable =
                createIterableImpl(h, signature, null, null);
        iterator = iterable.iterator();
        stmt.setResultSet(iterator);
    } else {
        iterator = stmt.getResultSet();
    }
    final List<List<Object>> list = new ArrayList<>();
    List<List<Object>> rows =
            MetaImpl.collect(signature.cursorFactory,
                    LimitIterator.of(iterator, fetchMaxRowCount), list);
    boolean done = fetchMaxRowCount == 0 || list.size() < fetchMaxRowCount;
    return new Meta.Frame(offset, done, (List<Object>) (List) rows);
}

开发者ID:bitnine-oss，项目名称:octopus，代码行数:22，代码来源:CalciteMetaImpl.java

示例20: CalciteSignature

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
CalciteSignature(String sql,
                 List<AvaticaParameter> parameterList,
                 Map<String, Object> internalParameters,
                 RelDataType rowType,
                 List<ColumnMetaData> columns,
                 Meta.CursorFactory cursorFactory,
                 List<RelCollation> collationList,
                 long maxRowCount,
                 Bindable<T> bindable,
                 Meta.StatementType statementType) {
    super(columns, sql, parameterList, internalParameters, cursorFactory,
            statementType);
    this.rowType = rowType;
    this.collationList = collationList;
    this.maxRowCount = maxRowCount;
    this.bindable = bindable;
}

开发者ID:bitnine-oss，项目名称:octopus，代码行数:18，代码来源:CalcitePrepare.java

注：本文中的org.apache.calcite.avatica.Meta类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java CacheEntryFactory类代码示例发布时间：2022-05-22

Java PATHCONF3Response类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18257|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9673|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8175|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8547|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8455|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9387|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8427|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7861|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8411|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java Meta类代码示例

示例1: create

示例2: fetch

示例3: create

示例4: ResultSetResponse

示例5: fromProto

示例6: deserialize

示例7: apply

示例8: toResultSet

示例9: apply

示例10: newPreparedStatement

示例11: newPreparedStatement

示例12: DataProvider

示例13: testConverUpdateToSeriesWithLikeComparison

示例14: testConvertInsertToSeriesWithTimestamp

示例15: testConvertInsertToSeriesAndMetricCommands

示例16: testConvertUpdateToSeriesAndMetricCommands

示例17: data

示例18: createResultSet

示例19: fetch

示例20: CalciteSignature

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

juven/maven-bash-completion: Maven Bash

win7系统注册表编辑器打开的操作方法

route101/mastoinker: Quick image view as

CVE-2022-21509

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053