Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
Parmita Mehta authored and Parmita Mehta committed Jul 14, 2017
1 parent 348d776 commit 9dbd8e5
Show file tree
Hide file tree
Showing 5 changed files with 13 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -161,7 +161,7 @@ public void updateState(
* @param result the table storing the result
* @param count column storing number of results (null for single-valued expressions)
* @throws DbException in case of error.
* @throws BufferOverflowException
* @throws BufferOverflowException
*/
public void eval(
@Nullable final ReadableTable input,
Expand Down Expand Up @@ -242,7 +242,7 @@ public ReadableColumn getResultCounts() {
* @return an {@link EvaluatorResult} containing the results and result counts of evaluating this expression on the
* entire TupleBatch
* @throws DbException
* @throws BufferOverflowException
* @throws BufferOverflowException
*/
public EvaluatorResult evalTupleBatch(final TupleBatch tb, final Schema outputSchema)
throws DbException, BufferOverflowException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -176,9 +176,10 @@ public void updateState(
* @param state state
* @param col column index of the state to be written to.
* @throws DbException in case of error
* @throws BufferOverflowException
* @throws BufferOverflowException
*/
public void evalGroups(final MutableTupleBuffer state, final int col) throws DbException, BufferOverflowException {
public void evalGroups(final MutableTupleBuffer state, final int col)
throws DbException, BufferOverflowException {
IntIterator keyIter = groups.keySet().intIterator();
while (keyIter.hasNext()) {
int key = keyIter.next();
Expand Down Expand Up @@ -209,7 +210,7 @@ public void evalGroups(final MutableTupleBuffer state, final int col) throws DbE
* @param result2 appendable table
* @param resultColIdx id of the result column.
* @throws DbException in case of error.
* @throws BufferOverflowException
* @throws BufferOverflowException
*/
public void readFromStream(final WritableColumn count, final WritableColumn result)
throws DbException, BufferOverflowException {
Expand All @@ -234,7 +235,7 @@ public void readFromStream(final WritableColumn count, final WritableColumn resu
int excepLength = dIn.readInt();
byte[] excp = new byte[excepLength];
dIn.readFully(excp);
throw new DbException(new String(excp,StandardCharsets.UTF_8));
throw new DbException(new String(excp, StandardCharsets.UTF_8));

} else {
// read the rest of the tuple
Expand Down
4 changes: 2 additions & 2 deletions src/edu/washington/escience/myria/operator/agg/Aggregate.java
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ protected void cleanup() throws DbException {
*
* @throws DbException if any error occurs.
* @return result TB.
* @throws BufferOverflowException
* @throws BufferOverflowException
*/
@Override
protected TupleBatch fetchNextReady() throws DbException, BufferOverflowException {
Expand Down Expand Up @@ -125,7 +125,7 @@ private boolean isCountAllOnlyAggregate() {
/**
* @return A batch's worth of result tuples from this aggregate.
* @throws DbException if there is an error.
* @throws BufferOverflowException
* @throws BufferOverflowException
*/
protected void generateResult() throws DbException, BufferOverflowException {
if (groupStates.numTuples() == 0) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,8 +42,8 @@ public StreamingAggregate(
*
* @throws DbException if any error occurs.
* @return result tuple batch
* @throws BufferOverflowException
* @throws BufferOverflowException
*
*/
@Override
protected TupleBatch fetchNextReady() throws DbException, BufferOverflowException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,8 +70,8 @@ public void initState(final MutableTupleBuffer state, final int offset) throws D
/**
* @param tb
* @param offset
* @throws DbException
* @throws BufferOverflowException
* @throws DbException
* @throws BufferOverflowException
*/
public void finalizePythonUpdaters(final MutableTupleBuffer tb, final int offset)
throws DbException, BufferOverflowException {
Expand Down

0 comments on commit 9dbd8e5

Please sign in to comment.