Extract the payload form each record.

@param records the list of records
@param <P>     the type of payload
@return the list of payloads
14972
public static <P> List<P> extractPayloads(final List<? extends Record<P>> records) {
        List<P> payloads = new ArrayList<>();
        for (Record<P> record : records) {
            payloads.add(record.getPayload());
        }
        return payloads;
    }
95088
public int getFieldTypes(Record record)
    {
        int iFieldTypes = m_iFieldTypes;
        if (iFieldTypes == -1)
        {
            iFieldTypes = BaseBuffer.PHYSICAL_FIELDS;
            if (!record.isAllSelected())
                iFieldTypes = BaseBuffer.DATA_FIELDS; // (Selected excluding virtual)
        }
        return iFieldTypes;
    }
354164
public static INDArray toMatrix(List<List<Writable>> records) {
        List<INDArray> toStack = new ArrayList<>();
        for(List<Writable> l : records){
            toStack.add(toArray(l));
        }

        return Nd4j.vstack(toStack);
    }
391911
@Override
	public Map<String, String> getHttpHeaders() {
		// revisit record had no HTTP headers in early days.
		if (headersResource.getRecordLength() == 0)
			return payloadResource.getHttpHeaders();
		else
			return headersResource.getHttpHeaders();
	}
746490
@VisibleForTesting
	protected ConsumerRecords<byte[], byte[]> getRecordsFromKafka() {
		ConsumerRecords<byte[], byte[]> records = consumer.poll(pollTimeout);
		if (rateLimiter != null) {
			int bytesRead = getRecordBatchSize(records);
			rateLimiter.acquire(bytesRead);
		}
		return records;
	}
187543
public java.util.List<RecordPatch> getRecordPatches() {
        if (recordPatches == null) {
            recordPatches = new com.amazonaws.internal.SdkInternalList<RecordPatch>();
        }
        return recordPatches;
    }
562526
def list_records(self, rtype=None, name=None, content=None):
        """"""
        opts = {}
        if rtype is not None:
            opts['type'] = rtype.upper()
        if name is not None:
            opts['name'] = self._relative_name(name)
        if content is not None:
            opts['value'] = self._txt_encode(content) if opts.get(
                'type', '') == 'TXT' else content

        records = []
        payload = self._api.domain.zone.record.list(
            self._api_key, self._zone_id, 0, opts)
        for record in payload:
            processed_record = {
                'type': record['type'],
                'name': self._full_name(record['name']),
                'ttl': record['ttl'],
                'content': record['value'],
                'id': record['id']
            }

            # Gandi will add quotes to all TXT record strings
            if processed_record['type'] == 'TXT':
                processed_record['content'] = self._txt_decode(
                    processed_record['content'])

            records.append(processed_record)

        LOGGER.debug("list_records: %s", records)
        return records
544227
@Deprecated
  protected byte[] getPayloadBytes(GenericRecord inputRecord) {
    try {
      return getFieldAsBytes(inputRecord, payloadField);
    } catch (Exception e) {
      return null;
    }
  }
439077
protected long getRecord(String record, IStatistic stats) {
    if (record == null || stats == null) {
      return 0;
    }
    IStatisticRecord statsRecord = stats.getRecordByName(record);
    if (statsRecord == null) {
      if (logger.isDebugEnabled()) {
        logger.debug("Warning: no record for {}, available: {}", record, Arrays.toString(stats.getRecords()));
      }
      return 0;
    }
    return statsRecord.getValueAsLong();
  }
1372299
private function transformRecords(RecordCollection $records, array $transformers, $context)
    {
        foreach ($transformers as $transformer) {
            if ($transformer instanceof PorterAware) {
                $transformer->setPorter($this);
            }

            $records = $transformer->transform($records, $context);
        }

        return $records;
    }
705384
public java.util.List<BillingRecord> getBillingRecords() {
        if (billingRecords == null) {
            billingRecords = new com.amazonaws.internal.SdkInternalList<BillingRecord>();
        }
        return billingRecords;
    }
913013
def _get_records(event):
    """"""
    try:
        recs, _ = unpack_kinesis_event(event, deserializer=None)
    except KeyError:
        # If not a Kinesis event, just unpack the records
        recs = event["Records"]
    return recs
207514
private void processSingleRecord(Record record) {
        // TODO Add your own record processing logic here

        String data = null;
        try {
            // For this app, we interpret the payload as UTF-8 chars.
            data = decoder.decode(record.getData()).toString();
            // Assume this record came from AmazonKinesisSample and log its age.
            long recordCreateTime = new Long(data.substring("testData-".length()));
            long ageOfRecordInMillis = System.currentTimeMillis() - recordCreateTime;

            LOG.info(record.getSequenceNumber() + ", " + record.getPartitionKey() + ", " + data + ", Created "
                    + ageOfRecordInMillis + " milliseconds ago.");
        } catch (NumberFormatException e) {
            LOG.info("Record does not match sample record format. Ignoring record with data; " + data);
        } catch (CharacterCodingException e) {
            LOG.error("Malformed data: " + data, e);
        }
    }
1149363
public void fieldsToData(Rec record) throws DBException
    {
        BaseBuffer buffer = this.getNewDataBuffer();
        this.doSetHandle(buffer, DBConstants.DATA_SOURCE_HANDLE); // This way you can retrieve the current buffer.
        super.fieldsToData(record);
        buffer.finishBuffer();
    }
331240
public void addAll(HashMap<Integer, char[]> records) {
    for (Entry<Integer, char[]> e : records.entrySet()) {
      this.add(e.getValue(), e.getKey());
    }
  }
566830
public List<List<String>> getRecordsAsString() {
        if(records == null)
            records = new ArrayList<>();
        List<List<String>> ret = new ArrayList<>();
        for(SingleCSVRecord csvRecord : records) {
            ret.add(csvRecord.getValues());
        }
        return ret;
    }
1163134
@Override
	public void collect(Record record)
	{
		try {
			for (int i = 0; i < writers.length; i++) {
				this.writers[i].emit(record);
			}
		}
		catch (IOException e) {
			throw new RuntimeException("Emitting the record caused an I/O exception: " + e.getMessage(), e);
		}
		catch (InterruptedException e) {
			throw new RuntimeException("Emitting the record was interrupted: " + e.getMessage(), e);
		}
	}