Chris

ofx parser doesn't handle common stock transfers

2

A raw transaction entry like so: ``` RawTransactionEntry(filename='some.qfx', date=datetime.date(2000, 1, 1), fitid='1234567', trantype='TRANSFER', total=None, incometype=None, inv401ksource=None, memo='RECEIVE COMMON STOCKRECEIVE COMMON STOCK', name=None, trntype=None, uniqueid='12345M123', units=Decimal('123456.0'), unitprice=None, tferaction='IN', fees=None, commission=None, checknum=None)...

Support string keys with Avro values

33

We currently use Avro for the values of our messages. It appears that we're being forced to use Avro for the key as well, since the REST proxy seems to...

Decouple topics from tables and generalize SchemaRetriever

8

# Intro We have had a number of PRs and issues recently that are attempting to do two things: 1. Support more serialization formats 2. Support multiple schemas in the...

Add a config to set all columns to nullable

2

KCBQ currently translates the Kafka connect required/nullable settings for fields into BigQuery fields as-is. That is, if a field is required in Kafka connect's schema, it will be REQUIRED in...

It doesn't look like we have an integration test that verifies that autoUpdateSchema actually works.

Add environment variables for project and dataset

1

I'm trying to use the BQ emulator in a Github workflow. Github, unfortunately, does not allow workflows to set arguments the way `docker run` does. I've tried overriding the entrypoint,...

bigquery-emulator v0.4.2 google-cloud-bigquery 3.11.3 (python lib) When I run: ``` CREATE TABLE `test_dataset.test_table_required` ( test_string STRING NOT NULL, test_bytes BYTES NOT NULL, test_int64 INT64 NOT NULL, test_float64 FLOAT64 NOT NULL,...

Add support for `DEFAULT`

2

I'd like to be able to create tables like this: ``` CREATE TABLE `test_dataset.test_table_default` ( test_string STRING DEFAULT "default_value" ) ``` When I do this right now, it executes, but...

I'd like to run: ``` CREATE TABLE `test_dataset.test_table_description` ( test_string STRING OPTIONS(description="This is a test string column") ) ``` And have it create tables with the description set for the...

[Bug]: session.execute with JSON column returns JSON-encoded string not JSON object

9

### What happened? Follow on to #504. I noticed that this query still fails with latest patch: ``` rows = session.execute( f"SELECT metadata FROM catalog WHERE {query}" ).fetchall() ``` In...