GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/854
SAMZA-2035: Detect CachingTableDescriptor as remote table.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza cache
Alternatively
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/839
SAMZA-2021: Adding an API to rel converter to filter out system messages.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza system
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/836
SAMZA-2017: Update committer doc
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza new
Alternatively you can review and apply
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/834
SAMZA-2014: Samza-sql: Support table as both source (for join) and
destination in the same application
While parsing queries in an application, with in SamzaSqlApplicationConfig,
we collect all
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/821
SAMZA-2007: Samza-sql - Fix Samza-SQL to not expect LogicalTableModify in
the Calcite plan.
This is required for supporting schema evolution without failing the jobs.
You can merge this pull
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/812
SAMZA-2001 Samza-sql: Handle null records in rel converter and in joins
* Synced some AvroRelConverter fixes from linkedin version.
* Null value handling in AvroRelConverter and Join function
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/811
SAMZA-1994 Table API: Add missed key lookups metric for table reads
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza metric
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/804
SAMZA-1991: Samza-sql: Implement DSL converter plugin manager
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza plugin
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/800
SAMZA-1986: Samza-sql: Use system name along with stream name for streamId
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/794
SAMZA-1616: Samza-Sql - Support remote table for stream-table join
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza remote
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/774
Samza-sql: Change Calcite sql type for samza sql rel message __key__ to
accept any format
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/762
SAMZA-1903: Samza-sql - Fix stream-table join to work with udfs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza udf
Github user atoomula closed the pull request at:
https://github.com/apache/samza/pull/655
---
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/742
SAMZA-1953: Remove TableDescriptorsProvider interface
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza tablefixes1
Alternatively
Github user atoomula closed the pull request at:
https://github.com/apache/samza/pull/727
---
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/727
SAMZA-1953: Remove TableDescriptorsProvider interface
Also cleaned up few Samza-sql warnings.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/689
Adding connectors overview doc
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza connector
Alternatively you can review and apply
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/676
SAMZA-1927: Samza-sql - always repartition the stream denoted by
stream-table join.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/667
Updated doc for Kinesis Connector
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza kinesisdocs
Alternatively you can review
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/655
Samza-sql: Fixing join to work with udfs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza udf
Alternatively you can review
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/630
Samza SQL: Code re-org to accomodate Samza SQL engine to take Calcite IR as
input
This PR has the following changes:
- Let QueryTranslator take Calcite IR as input
- Include 'INSERT
Github user atoomula closed the pull request at:
https://github.com/apache/samza/pull/625
---
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/625
Samza SQL: Code re-org to accomodate 'INSERT INTO' into the calcite plan
and basic DSLConverter framework.
This PR has the following changes:
* Include 'INSERT INTO' sql statement for Calcite
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/577
SAMZA-1782: Making getTableSpecs API in TableConfigGenerator util class
public
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza
Github user atoomula closed the pull request at:
https://github.com/apache/samza/pull/574
---
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/575
SAMZA-1779: Fix SamzaSql AvroRelConverter to handle BYTES and FIXED avro
schema types
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/574
Fix SamzaSql AvroRelConverter to handle BYTES and FIXED avro schema types
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza byte
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/558
Fix JsonRelConverter to recursively convert relRecords.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza sql1
Alternatively you
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/556
Table API: support table in low level API
Code changes to support table in low level API.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/545
SAMZA-1740: Moving SamzaSqlRelRecord to samza-api as it is needed to be
used in UDFs
Please see description in the ticket.
You can merge this pull request into a Git repository by running
Github user atoomula closed the pull request at:
https://github.com/apache/samza/pull/521
---
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/533
SAMZA-1728: BootstrappingChooser - Call checkOffset only for a lagging
partition while choosing.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/495
SAMZA-1693: Samza-sql - Adding Serde for rel record and few other minor
fixes for Avro and Rel conversion.
Adding Serde for rel record, as calcite expects the keys to be in string
format. Rel
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/481
SAMZA-1681: Samza-sql - Add support for handling older record schema
versions in AvroRelConverter
You can merge this pull request into a Git repository by running:
$ git pull https
Github user atoomula closed the pull request at:
https://github.com/apache/samza/pull/477
---
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/478
SAMZA-1651: Samza-sql - Implement GROUP BY SQL operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza groupby1
Alternatively
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/477
SAMZA-1651: Samza-sql - Implement GROUP BY SQL operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza groupby
Alternatively
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/472
SAMZA-1650: Fix for firing trigger at the end of trigger interval for
tumbling window
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/464
SAMZA-1619: Samza-sql: Support serialization of nested samza sql relational
message
Added support for serialization of nested samza sql rel message and
accordingly fixed the conversion of nested
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/457
KinesisConfig: Making getProxyHost and getProxyPort APIs protected
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza kconfig
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/443
Fix BootstrappingChooser to compare offsets via systemAdmin
offsetComparator to determine the end of bootstrap.
Please note that I have replaced offset equality check with
offsetComparator
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/425
Add stream-table join support for samza sql
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza join
Alternatively you can review
Github user atoomula closed the pull request at:
https://github.com/apache/samza/pull/360
---
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/384
Adding docs for Kinesis consumer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza kinesis-docs
Alternatively you can review
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/383
Make AllSspToSingleTaskGrouper work with Yarn and ZK JobCoordinator
Sending a fresh review as I lost the earlier diffs. This is the new
approach that we discussed by adding the processor list
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/368
Kinesis system consumer implementation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza kinesis
Alternatively you can review
GitHub user atoomula opened a pull request:
https://github.com/apache/samza/pull/360
Extend AllSspToSingleTaskGrouper to work with Yarn and ZK JobCoordinator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/atoomula/samza grouper
47 matches
Mail list logo
