本文整理了Java中io.confluent.ksql.parser.tree.QualifiedName.of方法的一些代码示例，展示了QualifiedName.of的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QualifiedName.of方法的具体详情如下：
包路径：io.confluent.ksql.parser.tree.QualifiedName
类名称：QualifiedName
方法名：of

QualifiedName.of介绍

暂无

代码示例

代码示例来源：origin: confluentinc/ksql

public static QualifiedName of(final String name) {
 requireNonNull(name, "name is null");
 return of(ImmutableList.of(name));
}

代码示例来源：origin: confluentinc/ksql

private static QualifiedName getQualifiedName(final SqlBaseParser.QualifiedNameContext context) {
 final List<String> parts = context
   .identifier().stream()
   .map(AstBuilder::getIdentifierText)
   .collect(toList());
 return QualifiedName.of(parts);
}

代码示例来源：origin: confluentinc/ksql

private WithQuery(final Optional<NodeLocation> location, final String name, final Query query,
         final Optional<List<String>> columnNames) {
 super(location);
 this.name = QualifiedName.of(requireNonNull(name, "name is null")).getParts().get(0);
 this.query = requireNonNull(query, "query is null");
 this.columnNames = requireNonNull(columnNames, "columnNames is null");
}

代码示例来源：origin: confluentinc/ksql

/**
 * If this DereferenceExpression looks like a QualifiedName, return QualifiedName.
 * Otherwise return null
 */
public static QualifiedName getQualifiedName(final DereferenceExpression expression) {
 final List<String> parts = tryParseParts(expression.base, expression.fieldName);
 return parts == null ? null : QualifiedName.of(parts);
}

代码示例来源：origin: confluentinc/ksql

private static QualifiedName getQualifiedName(final SqlBaseParser.QualifiedNameContext context) {
 final List<String> parts = context
   .identifier().stream()
   .map(AstBuilder::getIdentifierText)
   .collect(toList());
 return QualifiedName.of(parts);
}

代码示例来源：origin: confluentinc/ksql

public static QualifiedName of(final String first, final String... rest) {
 requireNonNull(first, "first is null");
 return of(ImmutableList.copyOf(Lists.asList(first, rest)));
}

代码示例来源：origin: confluentinc/ksql

public QualifiedName getSuffix() {
 return QualifiedName.of(name.getSuffix());
}

代码示例来源：origin: confluentinc/ksql

@Override
public Node visitConcatenation(final SqlBaseParser.ConcatenationContext context) {
 return new FunctionCall(
   getLocation(context.CONCAT()),
   QualifiedName.of("concat"), ImmutableList.of(
   (Expression) visit(context.left),
   (Expression) visit(context.right)
 )
 );
}

代码示例来源：origin: confluentinc/ksql

private FunctionCall getNewFunctionCall(
  final DereferenceExpression dereferenceExpression,
  final Object context
) {
 final Expression createFunctionResult
   = (Expression) process(dereferenceExpression.getBase(), context);
 final String fieldName = dereferenceExpression.getFieldName();
 return new FunctionCall(
   QualifiedName.of("FETCH_FIELD_FROM_STRUCT"),
   ImmutableList.of(createFunctionResult, new StringLiteral(fieldName)));
}

代码示例来源：origin: confluentinc/ksql

@Override
public Node visitInsertInto(final SqlBaseParser.InsertIntoContext context) {
 Optional<Expression> partitionByColumn = Optional.empty();
 if (context.identifier() != null) {
  partitionByColumn = Optional.of(new QualifiedNameReference(
    QualifiedName.of(getIdentifierText(context.identifier()))));
 }
 return new InsertInto(
   Optional.of(getLocation(context)),
   getQualifiedName(context.qualifiedName()),
   (Query) visitQuery(context.query()),
   partitionByColumn);
}

代码示例来源：origin: confluentinc/ksql

@Test
public void shouldFormatFunctionCountStar() {
 final FunctionCall functionCall = new FunctionCall(QualifiedName.of("function", "COUNT"), Collections.emptyList());
 assertThat(ExpressionFormatter.formatExpression(functionCall), equalTo("function.COUNT(*)"));
}

代码示例来源：origin: confluentinc/ksql

private DropStream mockDropStream(final String name) {
 final DropStream mockDropStream = mock(DropStream.class);
 expect(mockDropStream.getName()).andStubReturn(QualifiedName.of(name));
 expect(mockDropStream.getStreamName()).andStubReturn(QualifiedName.of(name));
 expect(mockParser.parseSingleStatement("DROP"))
   .andReturn(new PreparedStatement<>("DROP", mockDropStream));
 return mockDropStream;
}

代码示例来源：origin: confluentinc/ksql

private static PrintTopic printTopic(final String name, final boolean fromBeginning) {
 return new PrintTopic(
   new NodeLocation(0, 1),
   QualifiedName.of(name),
   fromBeginning,
   Optional.empty()
 );
}

代码示例来源：origin: confluentinc/ksql

@Test
public void shouldFormatCreateWithEmptySchema() {
 final CreateStream createStream = new CreateStream(
   QualifiedName.of("TEST"),
   Collections.emptyList(),
   false,
   Collections.singletonMap(
     DdlConfig.KAFKA_TOPIC_NAME_PROPERTY,
     new StringLiteral("topic_test")
   ));
 final String sql = SqlFormatter.formatSql(createStream);
 final String expectedSql = "CREATE STREAM TEST \n WITH (KAFKA_TOPIC='topic_test');";
 assertThat(sql, equalTo(expectedSql));
}

代码示例来源：origin: confluentinc/ksql

private CreateStreamAsSelect mockCSAS(final String name) {
 final CreateStreamAsSelect mockStatement = mock(CreateStreamAsSelect.class);
 expect(mockStatement.getName()).andStubReturn(QualifiedName.of(name));
 expect(mockStatement.getQuery()).andStubReturn(mockCSASQuery(name));
 expect(mockStatement.getProperties()).andStubReturn(Collections.emptyMap());
 expect(mockStatement.getPartitionByColumn()).andStubReturn(Optional.empty());
 return mockStatement;
}

代码示例来源：origin: confluentinc/ksql

@Test
public void shouldFormatQualifiedNameReference() {
 assertThat(ExpressionFormatter.formatExpression(new QualifiedNameReference(QualifiedName.of("name"))), equalTo("name"));
}

代码示例来源：origin: confluentinc/ksql

@Test
public void shouldFormatFunctionCallWithCount() {
 final FunctionCall functionCall = new FunctionCall(QualifiedName.of("function", "COUNT"),
   Collections.singletonList(new StringLiteral("name")));
 assertThat(ExpressionFormatter.formatExpression(functionCall), equalTo("function.COUNT('name')"));
}

代码示例来源：origin: confluentinc/ksql

private Query mockCSASQuery(final String name) {
 final Query mockQuery = mock(Query.class);
 final QuerySpecification mockQuerySpec = mock(QuerySpecification.class);
 final Table mockRelation = mock(Table.class);
 expect(mockQuery.getQueryBody()).andStubReturn(mockQuerySpec);
 expect(mockQuery.getLimit()).andStubReturn(Optional.empty());
 expect(mockQuerySpec.getInto()).andStubReturn(mockRelation);
 expect(mockRelation.getName()).andStubReturn(QualifiedName.of(name));
 return mockQuery;
}

代码示例来源：origin: confluentinc/ksql

@Test
public void shouldFormatFunctionWithDistinct() {
 final FunctionCall functionCall = new FunctionCall(new NodeLocation(1, 1),
   QualifiedName.of("function", "COUNT"),
   true,
   Collections.singletonList(new StringLiteral("name")));
 assertThat(ExpressionFormatter.formatExpression(functionCall), equalTo("function.COUNT(DISTINCT 'name')"));
}

代码示例来源：origin: confluentinc/ksql

@Test
public void shouldFormatFunctionCallWithWindow() {
 final FunctionCall functionCall = new FunctionCall(new NodeLocation(1, 1),
   QualifiedName.of("function"),
   Optional.of(new Window("window",
     new WindowExpression("blah", new TumblingWindowExpression(1L, TimeUnit.SECONDS)))),
   false,
   Collections.singletonList(new StringLiteral("name")));
 assertThat(ExpressionFormatter.formatExpression(functionCall),
   equalTo("function('name') OVER  WINDOW  WINDOW blah  TUMBLING ( SIZE 1 SECONDS ) "));
}