Skip to content

Conversation

@jerrypeng
Copy link
Contributor

Motivation

Add support for Pulsar SQL to be able to query offloaded ledgers

@jerrypeng jerrypeng added the area/sql Pulsar SQL related features label Apr 14, 2019
@jerrypeng jerrypeng added this to the 2.4.0 milestone Apr 14, 2019
@jerrypeng jerrypeng self-assigned this Apr 14, 2019
Schema schema = topicsToSchemas.get(topicSchemaName).getType() == SchemaType.AVRO ? AvroSchema.of(SchemaDefinition.<Foo>builder().withPojo(Foo.class).build()) : JSONSchema.of(SchemaDefinition.<Foo>builder().withPojo(Foo.class).build());

org.apache.pulsar.shade.io.netty.buffer.ByteBuf payload = org.apache.pulsar.shade.io.netty.buffer.Unpooled
io.netty.buffer.ByteBuf payload = io.netty.buffer.Unpooled
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Could we just use ByteBuf now?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

we can

Copy link
Contributor

@merlimat merlimat left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

👍

@jerrypeng
Copy link
Contributor Author

rerun java8 tests
rerun integration tests

@jerrypeng
Copy link
Contributor Author

rerun java8 tests

1 similar comment
@jerrypeng
Copy link
Contributor Author

rerun java8 tests

@jerrypeng
Copy link
Contributor Author

rerun cpp tests

@jerrypeng
Copy link
Contributor Author

rerun integration tests

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

area/sql Pulsar SQL related features

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants