GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/295
Samza SQL implementation for basic projects, filtering and UDFs
## Samza SQL implementation for basic projects, filtering and
## Design document:
https://docs.google.com/document
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/374
Documentation for Samza SQL
Adds documentation on how to use Samza SQL on a local machine and on a yarn
environment. Right now this documentation points to the samza-sql-tools that is
outside
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/386
Support for UDFs in where clauses
The existing version of the udf implementation doesn't seem to supported in
the where clauses because the Type of the object returned is "ANY" a
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/403
Fix for the TestSamzaSqlApplicationConfig.testConfigInit
Currently testConfigInit checks for a hardcoded number for udfs. Whenever a
new UDF is added, This test is going to fail if it is not
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/405
SAMZA-1556: Adding support for multi level sources in queries
Right now Samza SQL supports queries with just two levels i.e. `select *
from foo.bar`. But there can be sources that are identified
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/421
Support source types where the last part of the source is not the streamName
Contains following fixes
1. Right now Samza SQL framework assumes that the last part of the source
is the
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/424
Fixes to get the build working with Scala 2.10 build
The fixes needed to get the build working with the Scala 2.10.
You can merge this pull request into a Git repository by running:
$ git
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/440
Infinite loop when trying to use SamzaSqlApplicationRunner in yarn mode
Right now when we try to use the SamzaSqlApplicationRunner in yarn mode it
goes into the infinite loop because the
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/453
Making event hub configs Samza compliant
Couple of issues
1. Right now event hub doesn't follow the samza's config convention of
naming the secrets as "sensitive&qu
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/454
Skipping large messages in the EventHub system producer
EventHubs have restriction on maximum message sizes that can be allowed.
Adding a `systems.%s.eventhubs.skipMessagesLargerThanBytes` that
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/458
Refactoring the EventHub System Producer into reusable AsyncSystemProducer
and NoFlushAsyncSystemProducer
Refactoring eventhub system producer into common reusable components
1
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/467
Upgrade to latest event hub version (1.0.1)
* Upgrade to the latest event hub version 1.0.1
* Adding configs for prefetchCount and maxEventPerPoll
* Fixing a race condition in event hub
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/473
SystemConsumer and Producer benchmark tests
* Tests to benchmark the performance of the system consumers and producers.
* Config to test the benchmark for the event hub system producer and
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/528
Implementing the fetchSinkInfo in ConfigBasedIOResolver
1. I think we missed implementing the fetchSinkInfo method in the
ConfigBasedResolver when the API was introduced which is breaking the
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/557
Pass full config to the IO resolver
SQL IO Resolver needs full configs so that it can filter out the configs
specific to the source that the SQL application is interested in. This change
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/614
SAMZA 1820: Support for all the calcite timestamp functions
The DataContextImpl that we are passing to Calcite supports just the
current_timestamp. This change adds support for all the other
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/695
Samza SQL Documentation
This is initial Samza SQL documentation. @vjagadish I still am tracking
your comment to add more details on various queries, Samza SQL components. I
think i need more
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/763
Print the logical plan during query planning
Minor fix to print the logical plan.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/srinipunuru
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/784
Fix to make Samza SQL applications work after the Runner refactoring
With recent change in Samza, Constructor signature for ApplicationRunner
has changed. But the SamzaSQLApplicationRunner was
GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/885
Type system for Samza SQL and Support for types in UDFS
This checkin adds
1. Type system for Samza SQL. Previously Samza SQL was using Calcite's
relational type system. We ne
20 matches
Mail list logo
