class TransientQueryMetadata extends QueryMetadata {

  @Override
  public KsqlQueryType getQueryType() {
    return KsqlQueryType.PUSH;
  }

  public  TransientQueryMetadata(
      final String statementString,
      final LogicalSchema logicalSchema,
      final Set<SourceName> sourceNames,
      final String executionPlan,
      final BlockingRowQueue rowQueue,
      final String queryApplicationId,
      final Topology topology,
      final KafkaStreamsBuilder kafkaStreamsBuilder,
      final Map<String, Object> streamsProperties,
      final Map<String, Object> overriddenProperties,
      final Consumer<QueryMetadata> closeCallback,
      final long closeTimeout,
      final int maxQueryErrorsQueueSize
  );

}