Examples of RandomAccessInputView

Examples of eu.stratosphere.pact.runtime.io.RandomAccessInputView

130
131
132
133
134
135
136
137
138
139
140
141
    this.recordBufferSegments = new ArrayList<MemorySegment>(16);
   
    // the views for the record collections
    this.recordCollector = new SimpleCollectingOutputView(this.recordBufferSegments,
      new ListMemorySegmentSource(this.freeMemory), this.segmentSize);
    this.recordBuffer = new RandomAccessInputView(this.recordBufferSegments, this.segmentSize);
    this.recordBufferForComparison = new RandomAccessInputView(this.recordBufferSegments, this.segmentSize);
   
    // set up normalized key characteristics
    if (this.comparator.supportsNormalizedKey()) {
      this.numKeyBytes = Math.min(this.comparator.getNormalizeKeyLen(), maxNormalizedKeyBytes);
      this.normalizedKeyFullyDetermines = !this.comparator.isNormalizedKeyPrefixOnly(this.numKeyBytes);
View Full Code Here

Examples of eu.stratosphere.pact.runtime.io.RandomAccessInputView

75
76
77
78
79
80
81
82
83
84
85
    this.fullSegments = new ArrayList<MemorySegment>(numPages);
    memoryManager.allocatePages(ownerTask, emptySegments, numPages);
   
    this.collectingView = new SimpleCollectingOutputView(this.fullSegments,
            new ListMemorySegmentSource(this.emptySegments), memoryManager.getPageSize());
    this.readView = new RandomAccessInputView(this.fullSegments, memoryManager.getPageSize());
   
    if (LOG.isDebugEnabled()) {
      LOG.debug("Iterator initalized using " + numPages + " memory buffers.");
    }
  }
View Full Code Here

Examples of org.apache.flink.runtime.io.disk.RandomAccessInputView

136
137
138
139
140
141
142
143
144
145
146
147
    this.recordBufferSegments = new ArrayList<MemorySegment>(16);
   
    // the views for the record collections
    this.recordCollector = new SimpleCollectingOutputView(this.recordBufferSegments,
      new ListMemorySegmentSource(this.freeMemory), this.segmentSize);
    this.recordBuffer = new RandomAccessInputView(this.recordBufferSegments, this.segmentSize);
    this.recordBufferForComparison = new RandomAccessInputView(this.recordBufferSegments, this.segmentSize);
   
    // set up normalized key characteristics
    if (this.comparator.supportsNormalizedKey()) {
      this.numKeyBytes = Math.min(this.comparator.getNormalizeKeyLen(), maxNormalizedKeyBytes);
      this.normalizedKeyFullyDetermines = !this.comparator.isNormalizedKeyPrefixOnly(this.numKeyBytes);
View Full Code Here

Examples of org.apache.flink.runtime.io.disk.RandomAccessInputView

80
81
82
83
84
85
86
87
88
89
90
    this.fullSegments = new ArrayList<MemorySegment>(numPages);
    memoryManager.allocatePages(ownerTask, emptySegments, numPages);
   
    this.collectingView = new SimpleCollectingOutputView(this.fullSegments,
            new ListMemorySegmentSource(this.emptySegments), memoryManager.getPageSize());
    this.readView = new RandomAccessInputView(this.fullSegments, memoryManager.getPageSize());
   
    if (LOG.isDebugEnabled()) {
      LOG.debug("Iterator initialized using " + numPages + " memory buffers.");
    }
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.