|
Change Parameter Type pages : List<Page> to pages : List<SerializedPage> in method public addPages(client HttpPageBufferClient, pages List<SerializedPage>) : boolean in class com.facebook.presto.operator.ExchangeClient.ExchangeClientCallback |
From |
To |
|
Change Parameter Type pages : Iterable<Page> to pages : Iterable<SerializedPage> in method private PagesResponse(taskInstanceId String, token long, nextToken long, pages Iterable<SerializedPage>, clientComplete boolean) in class com.facebook.presto.operator.HttpPageBufferClient.PagesResponse |
From |
To |
|
Change Parameter Type page : Page to pages : List<SerializedPage> in method public enqueue(partitionNumber int, pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.BroadcastOutputBuffer |
From |
To |
|
Change Parameter Type pages : List<Page> to pages : List<SerializedPage> in method public addPages(client HttpPageBufferClient, pages List<SerializedPage>) : boolean in class com.facebook.presto.operator.HttpPageBufferClient.ClientCallback |
From |
To |
|
Change Parameter Type pages : List<Page> to serializedPages : List<SerializedPage> in method public writeTo(serializedPages List<SerializedPage>, type Class<?>, genericType Type, annotations Annotation[], mediaType MediaType, httpHeaders MultivaluedMap<String,Object>, output OutputStream) : void in class com.facebook.presto.server.PagesResponseWriter |
From |
To |
|
Change Parameter Type page : Page to pages : List<SerializedPage> in method public enqueue(partitionNumber int, pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.PartitionedOutputBuffer |
From |
To |
|
Change Parameter Type pages : List<Page> to pages : List<SerializedPage> in method public addPages(client HttpPageBufferClient, pages List<SerializedPage>) : boolean in class com.facebook.presto.operator.TestHttpPageBufferClient.TestingClientCallback |
From |
To |
|
Change Parameter Type page : Page to pages : List<SerializedPage> in method public enqueue(pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.PartitionedOutputBuffer |
From |
To |
|
Change Parameter Type page : Page to serializedPage : SerializedPage in method public SerializedPageReference(serializedPage SerializedPage, referenceCount int, onDereference Runnable) in class com.facebook.presto.execution.buffer.ClientBuffer.SerializedPageReference |
From |
To |
|
Change Parameter Type page : Page to pages : List<SerializedPage> in method public enqueue(partition int, pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.LazyOutputBuffer |
From |
To |
|
Change Parameter Type pages : Collection<PageReference> to pages : Collection<SerializedPageReference> in method public enqueuePages(pages Collection<SerializedPageReference>) : void in class com.facebook.presto.execution.buffer.ClientBuffer |
From |
To |
|
Change Parameter Type pages : List<Page> to serializedPages : List<SerializedPage> in method public getSize(serializedPages List<SerializedPage>, type Class<?>, genericType Type, annotations Annotation[], mediaType MediaType) : long in class com.facebook.presto.server.PagesResponseWriter |
From |
To |
|
Change Parameter Type page : Page to page : SerializedPage in method private postProcessPage(page SerializedPage) : SerializedPage in class com.facebook.presto.operator.ExchangeClient |
From |
To |
|
Change Parameter Type pages : Iterable<Page> to pages : Iterable<SerializedPage> in method public createPagesResponse(taskInstanceId String, token long, nextToken long, pages Iterable<SerializedPage>, complete boolean) : PagesResponse in class com.facebook.presto.operator.HttpPageBufferClient.PagesResponse |
From |
To |
|
Change Parameter Type actualPage : Page to actualPage : SerializedPage in method private assertPageEquals(actualPage SerializedPage, expectedPage Page) : void in class com.facebook.presto.operator.TestExchangeClient |
From |
To |
|
Change Parameter Type blockEncodingSerde : BlockEncodingSerde to serde : PagesSerde in method public BinaryFileSpiller(serde PagesSerde, executor ListeningExecutorService, spillPath Path, spilledDataSize AtomicLong) in class com.facebook.presto.spiller.BinaryFileSpiller |
From |
To |
|
Change Parameter Type page : Page to pages : List<SerializedPage> in method public enqueue(pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.LazyOutputBuffer |
From |
To |
|
Change Parameter Type serde : BlockEncodingSerde to serde : PagesSerde in method package PageReader(serde PagesSerde, input SliceInput) in class com.facebook.presto.execution.buffer.PagesSerdeUtil.PageReader |
From |
To |
|
Change Parameter Type page : Page to page : List<SerializedPage> in method public enqueue(partition int, page List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.OutputBuffer |
From |
To |
|
Change Parameter Type pages : List<Page> to serializedPages : List<SerializedPage> in method public BufferResult(taskInstanceId String, token long, nextToken long, bufferComplete boolean, serializedPages List<SerializedPage>) in class com.facebook.presto.execution.buffer.BufferResult |
From |
To |
|
Change Parameter Type page : Page to pages : List<SerializedPage> in method public enqueue(pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.BroadcastOutputBuffer |
From |
To |
|
Change Parameter Type page : Page to page : List<SerializedPage> in method public enqueue(page List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.OutputBuffer |
From |
To |
|
Change Parameter Type pages : List<Page> to pages : List<SerializedPage> in method private addPages(pages List<SerializedPage>) : boolean in class com.facebook.presto.operator.ExchangeClient |
From |
To |
|
Move Attribute private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.operator.ExchangeClient to private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.sql.planner.LocalExecutionPlanner |
From |
To |
|
Move Attribute private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.operator.HttpPageBufferClient.PageResponseHandler to private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.execution.buffer.PagesSerde |
From |
To |
|
Move Attribute private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.spiller.BinarySpillerFactory to private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.execution.buffer.PagesSerdeFactory |
From |
To |
|
Move Attribute private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.operator.ExchangeClient to private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.server.StatementResource |
From |
To |
|
Move Attribute private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.operator.HttpPageBufferClient to private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.execution.buffer.PagesSerde |
From |
To |
|
Move Attribute private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.server.PagesResponseWriter to private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.server.StatementResource |
From |
To |
|
Move Attribute private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.spiller.BinaryFileSpiller to private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.execution.buffer.PagesSerde |
From |
To |
|
Move Attribute private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.server.PagesResponseWriter to private blockEncodingSerde : BlockEncodingSerde from class com.facebook.presto.execution.buffer.PagesSerde |
From |
To |
|
Change Variable Type page : Page to page : SerializedPage in method public getOutput() : Page in class com.facebook.presto.operator.ExchangeOperator |
From |
To |
|
Change Variable Type pageReferences : List<PageReference> to serializedPageReferences : List<SerializedPageReference> in method public enqueue(pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.BroadcastOutputBuffer |
From |
To |
|
Change Variable Type removedPage : PageReference to removedPage : SerializedPageReference in method private acknowledgePages(sequenceId long) : void in class com.facebook.presto.execution.buffer.ClientBuffer |
From |
To |
|
Change Variable Type removedPages : List<PageReference> to removedPages : List<SerializedPageReference> in method private acknowledgePages(sequenceId long) : void in class com.facebook.presto.execution.buffer.ClientBuffer |
From |
To |
|
Change Variable Type pageReferences : List<PageReference> to serializedPageReferences : List<SerializedPageReference> in method public enqueue(partitionNumber int, pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.PartitionedOutputBuffer |
From |
To |
|
Change Variable Type page : Page to serializedPage : SerializedPage in method public getPages(sequenceId long, maxSize DataSize) : BufferResult in class com.facebook.presto.operator.MockExchangeRequestProcessor.MockBuffer |
From |
To |
|
Change Variable Type result : List<Page> to result : List<SerializedPage> in method private processRead(sequenceId long, maxSize DataSize) : BufferResult in class com.facebook.presto.execution.buffer.ClientBuffer |
From |
To |
|
Change Variable Type pages : List<Page> to pages : List<SerializedPage> in method public handle(request Request, response Response) : PagesResponse in class com.facebook.presto.operator.HttpPageBufferClient.PageResponseHandler |
From |
To |
|
Change Variable Type page : Page to page : SerializedPage in method public pollPage() : SerializedPage in class com.facebook.presto.operator.ExchangeClient |
From |
To |
|
Change Variable Type responsePages : List<Page> to responsePages : List<SerializedPage> in method public getPages(sequenceId long, maxSize DataSize) : BufferResult in class com.facebook.presto.operator.MockExchangeRequestProcessor.MockBuffer |
From |
To |
|
Change Variable Type removedPages : List<PageReference> to removedPages : List<SerializedPageReference> in method public destroy() : void in class com.facebook.presto.execution.buffer.ClientBuffer |
From |
To |
|
Change Variable Type pageReference : PageReference to serializedPageReference : SerializedPageReference in method private addPage(buffer ClientBuffer, page Page) : AtomicBoolean in class com.facebook.presto.execution.buffer.TestClientBuffer |
From |
To |
|
Change Variable Type pages : List<Page> to pages : List<SerializedPage> in method public onSuccess(result PagesResponse) : void in class com.facebook.presto.operator.HttpPageBufferClient.sendGetResults.addCallback |
From |
To |
|
Change Variable Type pages : List<PageReference> to pages : List<SerializedPageReference> in method private noMoreBuffers() : void in class com.facebook.presto.execution.buffer.BroadcastOutputBuffer |
From |
To |
|
Change Variable Type pages : List<Page> to serializedPages : List<SerializedPage> in method public getResults(taskId TaskId, bufferId OutputBufferId, token long, maxSize DataSize, asyncResponse AsyncResponse) : void in class com.facebook.presto.server.TaskResource |
From |
To |
|
Change Variable Type page : PageReference to page : SerializedPageReference in method private processRead(sequenceId long, maxSize DataSize) : BufferResult in class com.facebook.presto.execution.buffer.ClientBuffer |
From |
To |
|
Change Variable Type page : Page to page : SerializedPage in method public getNextPage(maxWaitTime Duration) : SerializedPage in class com.facebook.presto.operator.ExchangeClient |
From |
To |
|
Rename Variable pageReference : PageReference to serializedPageReference : SerializedPageReference in method private addPage(buffer ClientBuffer, page Page) : AtomicBoolean in class com.facebook.presto.execution.buffer.TestClientBuffer |
From |
To |
|
Rename Variable page : Page to serializedPage : SerializedPage in method public getPages(sequenceId long, maxSize DataSize) : BufferResult in class com.facebook.presto.operator.MockExchangeRequestProcessor.MockBuffer |
From |
To |
|
Rename Variable pageReferences : List<PageReference> to serializedPageReferences : List<SerializedPageReference> in method public enqueue(pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.BroadcastOutputBuffer |
From |
To |
|
Rename Variable pageReferences : List<PageReference> to serializedPageReferences : List<SerializedPageReference> in method public enqueue(partitionNumber int, pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.PartitionedOutputBuffer |
From |
To |
|
Rename Variable pages : List<Page> to serializedPages : List<SerializedPage> in method public getResults(taskId TaskId, bufferId OutputBufferId, token long, maxSize DataSize, asyncResponse AsyncResponse) : void in class com.facebook.presto.server.TaskResource |
From |
To |
|
Change Attribute Type page : Page to serializedPage : SerializedPage in class com.facebook.presto.execution.buffer.ClientBuffer.SerializedPageReference |
From |
To |
|
Change Attribute Type blockEncodingSerde : BlockEncodingSerde to serde : PagesSerde in class com.facebook.presto.spiller.BinaryFileSpiller |
From |
To |
|
Change Attribute Type pages : List<Page> to pages : List<SerializedPage> in class com.facebook.presto.operator.TestHttpPageBufferClient.TestingClientCallback |
From |
To |
|
Change Attribute Type pages : List<Page> to pages : List<SerializedPage> in class com.facebook.presto.operator.HttpPageBufferClient.PagesResponse |
From |
To |
|
Change Attribute Type pageBuffer : LinkedBlockingDeque<Page> to pageBuffer : LinkedBlockingDeque<SerializedPage> in class com.facebook.presto.operator.ExchangeClient |
From |
To |
|
Change Attribute Type initialPagesForNewBuffers : List<PageReference> to initialPagesForNewBuffers : List<SerializedPageReference> in class com.facebook.presto.execution.buffer.BroadcastOutputBuffer |
From |
To |
|
Change Attribute Type serde : BlockEncodingSerde to serde : PagesSerde in class com.facebook.presto.execution.buffer.PagesSerdeUtil.PageReader |
From |
To |
|
Change Attribute Type pages : LinkedList<PageReference> to pages : LinkedList<SerializedPageReference> in class com.facebook.presto.execution.buffer.ClientBuffer |
From |
To |
|
Change Attribute Type pages : List<Page> to serializedPages : List<SerializedPage> in class com.facebook.presto.execution.buffer.BufferResult |
From |
To |
|
Change Attribute Type NO_MORE_PAGES : Page to NO_MORE_PAGES : SerializedPage in class com.facebook.presto.operator.ExchangeClient |
From |
To |
|
Change Attribute Type pages : BlockingQueue<Page> to serializedPages : BlockingQueue<SerializedPage> in class com.facebook.presto.operator.MockExchangeRequestProcessor.MockBuffer |
From |
To |
|
Rename Parameter blockEncodingSerde : BlockEncodingSerde to serde : PagesSerde in method public BinaryFileSpiller(serde PagesSerde, executor ListeningExecutorService, spillPath Path, spilledDataSize AtomicLong) in class com.facebook.presto.spiller.BinaryFileSpiller |
From |
To |
|
Rename Parameter page : Page to pages : List<SerializedPage> in method public enqueue(pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.LazyOutputBuffer |
From |
To |
|
Rename Parameter pages : List<Page> to serializedPages : List<SerializedPage> in method public writeTo(serializedPages List<SerializedPage>, type Class<?>, genericType Type, annotations Annotation[], mediaType MediaType, httpHeaders MultivaluedMap<String,Object>, output OutputStream) : void in class com.facebook.presto.server.PagesResponseWriter |
From |
To |
|
Rename Parameter page : Page to pages : List<SerializedPage> in method public enqueue(partitionNumber int, pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.PartitionedOutputBuffer |
From |
To |
|
Rename Parameter page : Page to pages : List<SerializedPage> in method public enqueue(partitionNumber int, pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.BroadcastOutputBuffer |
From |
To |
|
Rename Parameter page : Page to pages : List<SerializedPage> in method public enqueue(pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.PartitionedOutputBuffer |
From |
To |
|
Rename Parameter pages : List<Page> to serializedPages : List<SerializedPage> in method public BufferResult(taskInstanceId String, token long, nextToken long, bufferComplete boolean, serializedPages List<SerializedPage>) in class com.facebook.presto.execution.buffer.BufferResult |
From |
To |
|
Rename Parameter page : Page to pages : List<SerializedPage> in method public enqueue(pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.BroadcastOutputBuffer |
From |
To |
|
Rename Parameter page : Page to serializedPage : SerializedPage in method public SerializedPageReference(serializedPage SerializedPage, referenceCount int, onDereference Runnable) in class com.facebook.presto.execution.buffer.ClientBuffer.SerializedPageReference |
From |
To |
|
Rename Parameter page : Page to pages : List<SerializedPage> in method public enqueue(partition int, pages List<SerializedPage>) : ListenableFuture<?> in class com.facebook.presto.execution.buffer.LazyOutputBuffer |
From |
To |
|
Rename Parameter pages : List<Page> to serializedPages : List<SerializedPage> in method public getSize(serializedPages List<SerializedPage>, type Class<?>, genericType Type, annotations Annotation[], mediaType MediaType) : long in class com.facebook.presto.server.PagesResponseWriter |
From |
To |