Clone Tools
  • last updated 13 mins ago
Constraints
Constraints: committers
 
Constraints: files
Constraints: dates
Move merged files

    • -101
    • +0
    ./reader/IndexingStreamRecordReader.java
    • -98
    • +0
    ./reader/stream/StreamRecordReader.java
    • -72
    • +0
    ./reader/stream/StreamRecordReaderFactory.java
  1. … 161 more files in changeset.
Control Number of Readers for LocalFS Data

Change-Id: Ib9d5ece656220d5f562cc385f882c5ddfd3283a6

Reviewed-on: https://asterix-gerrit.ics.uci.edu/776

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <hubailmor@gmail.com>

    • -1
    • +2
    ./reader/IndexingStreamRecordReader.java
    • -65
    • +74
    ./reader/stream/LineRecordReader.java
    • -61
    • +67
    ./reader/stream/QuotedLineRecordReader.java
    • -2
    • +12
    ./reader/stream/StreamRecordReader.java
  1. … 21 more files in changeset.
ASTERIXDB-1360 Fix Error Message for Unknown Format

This change includes some refactoring for external

data. This refactoring makes the code less error prone

and separate data source selection from data parser

selection. It also fixes issue ASTERIXDB-1366 and adds

a test case for it as well.

Change-Id: Ib4aac833e30bd7c5a7706f5c8116383c2362c964

Reviewed-on: https://asterix-gerrit.ics.uci.edu/767

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Till Westmann <tillw@apache.org>

    • -0
    • +100
    ./reader/IndexingStreamRecordReader.java
    • -116
    • +0
    ./reader/stream/AbstractStreamRecordReader.java
    • -95
    • +0
    ./reader/stream/AbstractStreamRecordReaderFactory.java
    • -4
    • +3
    ./reader/stream/EmptyLineSeparatedRecordReader.java
    • -43
    • +0
    ./reader/stream/EmptyLineSeparatedRecordReaderFactory.java
    • -52
    • +0
    ./reader/stream/LineRecordReaderFactory.java
    • -8
    • +8
    ./reader/stream/SemiStructuredRecordReader.java
    • -51
    • +0
    ./reader/stream/SemiStructuredRecordReaderFactory.java
    • -0
    • +88
    ./reader/stream/StreamRecordReader.java
    • -0
    • +72
    ./reader/stream/StreamRecordReaderFactory.java
    • -7
    • +12
    ./reader/twitter/TwitterRecordReaderFactory.java
  1. … 21 more files in changeset.
Improve Error Handling in Local Directory Feeds

This change improves handling of two error types for filesystem

based feeds. The first one is the handling of IO Errors which

causes the input stream to be closed, and the second one is

reacting to missed filesystem events. In both cases, we scan the

directory and compare it with the history we have in order to

resume from where we last left off.

In addition, this change includes some refactoring in external

data. Particularly, we get rid of the stream provider layer and

instead, stream factories create input streams directly. This

is consistent with record reader factories which create readers

directly without reader providers.

Change-Id: I08d89229e33c91532b1038ba9f7a372f7ca1fdb5

Reviewed-on: https://asterix-gerrit.ics.uci.edu/720

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <hubailmor@gmail.com>

    • -1
    • +1
    ./converter/DCPRequestToRecordWithMetadataAndPKConverter.java
    • -2
    • +7
    ./reader/TestAsterixMembersReader.java
    • -1
    • +1
    ./reader/hdfs/AbstractCharRecordLookupReader.java
    • -3
    • +11
    ./reader/hdfs/HDFSRecordReader.java
    • -8
    • +33
    ./reader/stream/AbstractStreamRecordReader.java
    • -9
    • +8
    ./reader/stream/AbstractStreamRecordReaderFactory.java
    • -2
    • +2
    ./reader/stream/EmptyLineSeparatedRecordReader.java
    • -2
    • +2
    ./reader/stream/EmptyLineSeparatedRecordReaderFactory.java
  1. … 130 more files in changeset.
Fix Asterix Installer Test Cases

Many tests started to fail in installer after being

disabled for a long time. This change fixes the following:

1. asterix-installer: external library tests.

2. asterix-installer: recovery: query-after-restart.

Change-Id: Iefad5ac3ff754693025312f1e2fa01b08832514c

Reviewed-on: https://asterix-gerrit.ics.uci.edu/737

Reviewed-by: Ian Maxon <imaxon@apache.org>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

  1. … 34 more files in changeset.
Improve KV Generator

Currently, KV Generator produces the same documents when

running in parallel where the only difference is in the

key of the record. With this change, it produces different

Documents in each partition to produce more diverse set of

records.

Change-Id: Ia337be57f8394d74a98f3c72ebcaa584f277f34b

Reviewed-on: https://asterix-gerrit.ics.uci.edu/724

Reviewed-by: Michael Blow <michael.blow@couchbase.com>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Yingyi Bu <buyingyi@gmail.com>

  1. … 1 more file in changeset.
Support Change Feeds and Ingestion of Records with MetaData

This change allows feeds to perform upserts and deletes

in order to perform replication of an external data source.

The change does so by performing the following:

1. The adapter produces [PK][Record]. (Record == null --> delete)

2. The insert is replaced by an upsert operator.

Change-Id: If136a03d424970132dfb09f0dda56e160d4c0078

Reviewed-on: https://asterix-gerrit.ics.uci.edu/621

Reviewed-by: Yingyi Bu <buyingyi@gmail.com>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

    • -0
    • +186
    ./RecordWithMetadataAndPK.java
    • -0
    • +72
    ./converter/CSVToRecordWithMetadataAndPKConverter.java
    • -0
    • +124
    ./converter/CSVWithRecordConverterFactory.java
    • -0
    • +61
    ./converter/DCPConverterFactory.java
    • -0
    • +122
    ./converter/DCPRequestToRecordWithMetadataAndPKConverter.java
    • -0
    • +42
    ./converter/IRecordConverterFactory.java
    • -0
    • +26
    ./converter/IRecordToRecordWithMetadataAndPKConverter.java
    • -0
    • +55
    ./reader/RecordWithPKTestReaderFactory.java
    • -0
    • +88
    ./reader/TestAsterixMembersReader.java
    • -265
    • +0
    ./reader/couchbase/CouchbaseReader.java
  1. … 256 more files in changeset.
ASTERIXDB-1302 ASTERIXDB-1301 Fix Socket Feed Connection

A bug causes a read lock to never be released when a feed is

connected with "wait-for-completion" set to false. The bug

was fixed and a test case was added.

Another bug was causing the socket feed to not receive

connections correctly. The bug was fixed and a test case

was added.

Additionally, this change ensures that adapters have absolute

partitions to ensure consistency with regards to feed log

manager.

Change-Id: I8f6e982440d3577343f2479c3779653a9c3db614

Reviewed-on: https://asterix-gerrit.ics.uci.edu/660

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Ildar Absalyamov <ildar.absalyamov@gmail.com>

    • -3
    • +3
    ./reader/hdfs/HDFSLookupReaderFactory.java
    • -4
    • +7
    ./reader/rss/RSSRecordReaderFactory.java
    • -2
    • +2
    ./reader/stream/AbstractStreamRecordReaderFactory.java
    • -3
    • +3
    ./reader/stream/SemiStructuredRecordReader.java
  1. … 44 more files in changeset.
Enabled Feed Tests and Added External Library tests

Feed tests had been switched off for a while due to having too many

sporadic failures. Now, we are switching them back on.

In addition, a new set of tests have been added to test that external

library works as expected.

Change-Id: Idd1fccd136fa2645b2707bbf7c04e60991ae8d4a

Reviewed-on: https://asterix-gerrit.ics.uci.edu/625

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

    • -1
    • +7
    ./reader/couchbase/CouchbaseReader.java
    • -0
    • +10
    ./reader/hdfs/HDFSRecordReader.java
    • -0
    • +8
    ./reader/stream/AbstractStreamRecordReader.java
    • -0
    • +119
    ./reader/stream/EmptyLineSeparatedRecordReader.java
    • -0
    • +45
    ./reader/stream/EmptyLineSeparatedRecordReaderFactory.java
    • -2
    • +4
    ./reader/stream/SemiStructuredRecordReader.java
  1. … 195 more files in changeset.
Remove Trailing Whitespace

This change removes all trailing whitespace in

java files in asterixdb

Change-Id: I32cda384f71dd5237a3c63e83c661f1cf64dc0eb

Reviewed-on: https://asterix-gerrit.ics.uci.edu/646

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Till Westmann <tillw@apache.org>

  1. … 325 more files in changeset.
Add flush() to IFrameWriter

This method is expected to be used with feeds to push

frames all the way to storage when needed. As of now, it is

needed in two cases:

1. No activities in ingestion node and need to push content

so it can be stored.

2. When the ingestion node needs to move the checkpoint ahead

if the at least once semantics are used.

Two feeds make use of this function. The filesystem feed and

couchbase feed which was introduced as well in this change.

Change-Id: Id862ce9e9b1360864c6976f2aea2137092f51203

Reviewed-on: https://asterix-gerrit.ics.uci.edu/585

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <hubailmor@gmail.com>

    • -0
    • +138
    ./RecordWithMetadata.java
    • -78
    • +0
    ./reader/AbstractCharRecordLookupReader.java
    • -113
    • +0
    ./reader/AbstractHDFSLookupRecordReader.java
    • -90
    • +0
    ./reader/AbstractStreamRecordReader.java
    • -99
    • +0
    ./reader/AbstractStreamRecordReaderFactory.java
    • -234
    • +0
    ./reader/HDFSTextLineReader.java
    • -44
    • +0
    ./reader/LookupReaderFactoryProvider.java
    • -119
    • +0
    ./reader/QuotedLineRecordReader.java
    • -157
    • +0
    ./reader/SemiStructuredRecordReader.java
  1. … 89 more files in changeset.
remove end-of-line whitespace

Change-Id: I5c0415f47d4c3a9827574fbdab949b45718d9ea4

Reviewed-on: https://asterix-gerrit.ics.uci.edu/601

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Yingyi Bu <buyingyi@gmail.com>

  1. … 138 more files in changeset.
Feed Fixes and Cleanup

1. Introduce filesystem feed data source.

2. Fix the order of closing feed stages on disconnection.

3. Added Twitter feed to the compatibility utility to allow

using it with its alias.

4. First part of the feed log space.

5. Fixed the handling of duplicate key exception.

Change-Id: I4e8db26a810efd1fbaa52ceeb3efd0c8328ab070

Reviewed-on: https://asterix-gerrit.ics.uci.edu/574

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <hubailmor@gmail.com>

    • -1
    • +16
    ./reader/AbstractStreamRecordReader.java
    • -1
    • +11
    ./reader/SemiStructuredRecordReader.java
    • -4
    • +14
    ./reader/TwitterPushRecordReader.java
  1. … 412 more files in changeset.
First stage of external data cleanup

In this change, different parts of external data were refactored.

The goal was to make it more modular, easier to maintain and allow

higher flexibility for extension in addition to reducing code redundancy.

Change-Id: I04a8c4e494d8d1363992b6fe0bdbe6b2b3b7b767

Reviewed-on: https://asterix-gerrit.ics.uci.edu/566

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <hubailmor@gmail.com>

    • -0
    • +106
    ./CharArrayRecord.java
    • -0
    • +62
    ./GenericRecord.java
    • -0
    • +78
    ./reader/AbstractCharRecordLookupReader.java
    • -0
    • +113
    ./reader/AbstractHDFSLookupRecordReader.java
    • -0
    • +75
    ./reader/AbstractStreamRecordReader.java
    • -0
    • +99
    ./reader/AbstractStreamRecordReaderFactory.java
    • -0
    • +56
    ./reader/EmptyRecordReader.java
    • -0
    • +194
    ./reader/HDFSRecordReader.java
    • -0
    • +234
    ./reader/HDFSTextLineReader.java
    • -0
    • +108
    ./reader/LineRecordReader.java
    • -0
    • +44
    ./reader/LookupReaderFactoryProvider.java
    • -0
    • +115
    ./reader/QuotedLineRecordReader.java
    • -0
    • +92
    ./reader/RCLookupReader.java
    • -0
    • +177
    ./reader/RSSRecordReader.java
    • -0
    • +147
    ./reader/SemiStructuredRecordReader.java
  1. … 329 more files in changeset.